Skip to main content

spawn_reader_writer

atomr_remote::reader_writer

Function spawn_reader_writer 

Source 
pub fn spawn_reader_writer<T>(
    transport: Arc<T>,
    outbound_capacity: usize,
) -> ReaderWriterHandle<T::Frame, T::OutFrame>
where
    T: RawTransport,
Expand description

Spawn a reader/writer pair around transport. The reader pumps inbound frames into a tokio::mpsc channel; the writer drains the outbound channel onto the wire. Either failure stops both.

Bounded outbound is intentional: under back-pressure the sender blocks rather than queues unbounded — falls back to the OverflowStrategy configured on RemoteSettings (Phase 5.G).