Struct TokioTcp 

pub struct TokioTcp;

Implementations

impl TokioTcp

pub fn outgoing_connection<A>( addr: A, chunk_size: usize, ) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TcpConnection>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Opens a plain TCP outgoing connection as a coupled byte flow.

TLS and UDP are outside WP-12b and intentionally deferred. Reads are bounded by a capacity-1 channel: once one chunk is waiting for downstream demand, the Tokio task stops reading until the stream consumes it. The flow does not hide an unbounded receive buffer.

pub fn outgoing_connection_default<A>( addr: A, ) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TcpConnection>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

pub fn bind<A>( addr: A, chunk_size: usize, ) -> Source<TcpIncomingConnection, StreamCompletion<TcpBinding>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Binds a plain TCP listener and emits accepted incoming connections.

Each accepted connection carries independent byte source/sink halves and can be converted into a coupled flow. The accept loop is demand-gated: one downstream pull permits one Tokio accept. TLS and UDP are deferred.

pub fn bind_default<A>( addr: A, ) -> Source<TcpIncomingConnection, StreamCompletion<TcpBinding>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,