libp2p.network.connection package¶
Submodules¶
libp2p.network.connection.exceptions module¶
-
exception
libp2p.network.connection.exceptions.
RawConnError
¶
libp2p.network.connection.net_connection_interface module¶
-
class
libp2p.network.connection.net_connection_interface.
INetConn
¶ Bases:
libp2p.io.abc.Closer
-
event_started
: trio.Event = None¶
-
abstract
get_streams
() → Tuple[libp2p.network.stream.net_stream_interface.INetStream, ...]¶
-
muxed_conn
: IMuxedConn = None¶
-
abstract async
new_stream
() → libp2p.network.stream.net_stream_interface.INetStream¶
-
libp2p.network.connection.raw_connection module¶
-
class
libp2p.network.connection.raw_connection.
RawConnection
(stream: libp2p.io.abc.ReadWriteCloser, initiator: bool)¶ Bases:
libp2p.network.connection.raw_connection_interface.IRawConnection
-
async
close
() → None¶
-
is_initiator
: bool = None¶
-
async
read
(n: int = None) → bytes¶ Read up to
n
bytes from the underlying stream. This call is delegated directly to the underlyingself.reader
.Raise RawConnError if the underlying connection breaks
-
stream
: ReadWriteCloser = None¶
-
async
write
(data: bytes) → None¶ Raise RawConnError if the underlying connection breaks.
-
async
libp2p.network.connection.raw_connection_interface module¶
-
class
libp2p.network.connection.raw_connection_interface.
IRawConnection
¶ Bases:
libp2p.io.abc.ReadWriteCloser
A Raw Connection provides a Reader and a Writer.
-
is_initiator
: bool = None¶
-
libp2p.network.connection.swarm_connection module¶
-
class
libp2p.network.connection.swarm_connection.
SwarmConn
(muxed_conn: libp2p.stream_muxer.abc.IMuxedConn, swarm: Swarm)¶ Bases:
libp2p.network.connection.net_connection_interface.INetConn
-
async
close
() → None¶
-
event_closed
: trio.Event = None¶
-
get_streams
() → Tuple[libp2p.network.stream.net_stream.NetStream, ...]¶
-
property
is_closed
¶
-
muxed_conn
: IMuxedConn = None¶
-
async
new_stream
() → libp2p.network.stream.net_stream.NetStream¶
-
remove_stream
(stream: libp2p.network.stream.net_stream.NetStream) → None¶
-
async
start
() → None¶
-
streams
: Set[NetStream] = None¶
-
swarm
: 'Swarm' = None¶
-
async