UDXSessionConn class

Implemented types

• MuxedConn
• TransportConn

Constructors

UDXSessionConn.new({required UDPSocket udpSocket, required UDXStream initialStream, required MultiAddr localMultiaddr, required MultiAddr remoteMultiaddr, required UDXTransport transport, required ConnManager connManager, PeerId? localPeer, required bool isDialer, void onClosed(UDXSessionConn conn)?})

Properties

hashCode → int

The hash code for this object.

no setter, inherited

id → String

ID returns an identifier that uniquely identifies this Conn within this host, during this run. Connection IDs may repeat across restarts.

final

initialP2PStream ↔ UDXP2PStreamAdapter

late, final

isClosed → bool

Returns whether a connection is fully closed, so it can be garbage collected.

no setter, override

localMultiaddr → MultiAddr

LocalMultiaddr returns the local Multiaddr associated with this connection

no setter, override

localPeer → PeerId

LocalPeer returns our peer ID

no setter, override

onClose → Future<void>

no setter

remoteMultiaddr → MultiAddr

RemoteMultiaddr returns the remote Multiaddr associated with this connection

no setter, override

remotePeer → PeerId

RemotePeer returns the peer ID of the remote peer.

no setter, override

remotePublicKey → Future<PublicKey?>

RemotePublicKey returns the public key of the remote peer.

no setter, override

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

scope → ConnScope

Scope returns the user view of this connection's resource scope

no setter, override

socket → Socket

no setter, override

stat → ConnStats

Stat stores metadata pertaining to this conn.

no setter, override

state → ConnState

ConnState returns information about the connection state.

no setter, override

streams → Future<List<P2PStream>>

GetStreams returns all open streams over this conn.

no setter, override

transport → Transport

no setter

Methods

acceptStream() → Future<MuxedStream>

Accepts a stream opened by the other side.

override

close() → Future<void>

Closes the stream muxer and the the underlying connection.

override

closeWithError(dynamic error, [StackTrace? stackTrace]) → Future<void>

handleRemoteOpenedStream(UDXPacket packet, Uint8List rawData, InternetAddress remoteAddress, int remotePort) → void

newStream(Context context, [int? streamId]) → Future<P2PStream>

NewStream constructs a new Stream over this conn.

override

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

notifyActivity() → void

Notifies that activity has occurred on this transport connection, potentially due to activity on a multiplexed stream over it. This can be used by multiplexers to inform the connection manager.

override

openStream(Context context) → Future<MuxedStream>

Creates a new stream.

override

read([int? length]) → Future<Uint8List>

Reads data from the connection. If length is provided, reads exactly that many bytes. Otherwise, reads whatever is available.

override

setReadTimeout(Duration timeout) → void

Sets a timeout for read operations.

override

setRemotePeerDetails(PeerId peerId, PublicKey pubKey, String securityProto) → void

setWriteTimeout(Duration timeout) → void

Sets a timeout for write operations.

override

toString() → String

A string representation of this object.

inherited

write(Uint8List data) → Future<void>

Writes data to the connection.

override

Operators

operator ==(Object other) → bool

The equality operator.

inherited