Rename stream muxer initiator flags
This commit is contained in:
parent
c0452c961b
commit
5810174374
|
@ -69,7 +69,7 @@ class Mplex(IMuxedConn):
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def is_initiator(self) -> bool:
|
def is_initiator(self) -> bool:
|
||||||
return self.secured_conn.initiator
|
return self.secured_conn.is_initiator
|
||||||
|
|
||||||
async def close(self) -> None:
|
async def close(self) -> None:
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -56,7 +56,7 @@ class MuxerMultistream:
|
||||||
"""
|
"""
|
||||||
protocol: TProtocol
|
protocol: TProtocol
|
||||||
communicator = MultiselectCommunicator(conn)
|
communicator = MultiselectCommunicator(conn)
|
||||||
if conn.initiator:
|
if conn.is_initiator:
|
||||||
protocol = await self.multiselect_client.select_one_of(
|
protocol = await self.multiselect_client.select_one_of(
|
||||||
tuple(self.transports.keys()), communicator
|
tuple(self.transports.keys()), communicator
|
||||||
)
|
)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user