libp2p.network.connection package

Submodules

libp2p.network.connection.exceptions module

exception libp2p.network.connection.exceptions.RawConnError

Bases: libp2p.io.exceptions.IOException

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 underlying self.reader.

Raise RawConnError if the underlying connection breaks

stream: ReadWriteCloser = None
async write(data: bytes) → None

Raise RawConnError if the underlying connection breaks.

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

Module contents