diff --git a/libp2p/stream_muxer/mplex/mplex.py b/libp2p/stream_muxer/mplex/mplex.py index 4ef0300..307e78d 100644 --- a/libp2p/stream_muxer/mplex/mplex.py +++ b/libp2p/stream_muxer/mplex/mplex.py @@ -69,7 +69,7 @@ class Mplex(IMuxedConn): @property def is_initiator(self) -> bool: - return self.secured_conn.initiator + return self.secured_conn.is_initiator async def close(self) -> None: """ diff --git a/libp2p/stream_muxer/muxer_multistream.py b/libp2p/stream_muxer/muxer_multistream.py index 7f6ee07..00e1428 100644 --- a/libp2p/stream_muxer/muxer_multistream.py +++ b/libp2p/stream_muxer/muxer_multistream.py @@ -56,7 +56,7 @@ class MuxerMultistream: """ protocol: TProtocol communicator = MultiselectCommunicator(conn) - if conn.initiator: + if conn.is_initiator: protocol = await self.multiselect_client.select_one_of( tuple(self.transports.keys()), communicator )