libp2p.transport.tcp package¶
Submodules¶
libp2p.transport.tcp.tcp module¶
-
class
libp2p.transport.tcp.tcp.TCP¶ Bases:
libp2p.transport.transport_interface.ITransport-
create_listener(handler_function: Callable[[libp2p.io.abc.ReadWriteCloser], Awaitable[None]]) → libp2p.transport.tcp.tcp.TCPListener¶ create listener on transport.
- Parameters
handler_function – a function called when a new connection is received that takes a connection as argument which implements interface-connection
- Returns
a listener object that implements listener_interface.py
-
async
dial(maddr: multiaddr.multiaddr.Multiaddr) → libp2p.network.connection.raw_connection_interface.IRawConnection¶ dial a transport to peer listening on multiaddr.
- Parameters
maddr – multiaddr of peer
- Returns
RawConnection if successful
- Raises
OpenConnectionError – raised when failed to open connection
-
-
class
libp2p.transport.tcp.tcp.TCPListener(handler_function: Callable[[libp2p.io.abc.ReadWriteCloser], Awaitable[None]])¶ Bases:
libp2p.transport.listener_interface.IListener-
async
close() → None¶
-
get_addrs() → Tuple[multiaddr.multiaddr.Multiaddr, ...]¶ retrieve list of addresses the listener is listening on.
- Returns
return list of addrs
-
async
listen(maddr: multiaddr.multiaddr.Multiaddr, nursery: trio.Nursery) → None¶ put listener in listening mode and wait for incoming connections.
- Parameters
maddr – maddr of peer
- Returns
return True if successful
-
listeners: List[trio.SocketListener] = None¶
-
async