mirror of
https://github.com/varun-r-mallya/py-libp2p.git
synced 2026-02-12 16:10:57 +00:00
Rename stream muxer initiator flags
This commit is contained in:
@ -23,7 +23,7 @@ class IMuxedConn(ABC):
|
|||||||
|
|
||||||
@property
|
@property
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
def initiator(self) -> bool:
|
def is_initiator(self) -> bool:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
|
|||||||
@ -68,7 +68,7 @@ class Mplex(IMuxedConn):
|
|||||||
self._tasks.append(asyncio.ensure_future(self.handle_incoming()))
|
self._tasks.append(asyncio.ensure_future(self.handle_incoming()))
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def initiator(self) -> bool:
|
def is_initiator(self) -> bool:
|
||||||
return self.secured_conn.initiator
|
return self.secured_conn.initiator
|
||||||
|
|
||||||
async def close(self) -> None:
|
async def close(self) -> None:
|
||||||
|
|||||||
Reference in New Issue
Block a user