Struct bolic_network::hub::transport::stream::NonBlockingStreamAdapter

pub struct NonBlockingStreamAdapter { /* private fields */ }

NonBlockingStreamAdapter helps convert split async read/write streams into a NonBlockingStream by spawning async tasks. Streams that support a native non-blocking implementation (e.g., mio) in both directions should directly implement NonBlockingStream.

Implementations

impl NonBlockingStreamAdapter

pub fn new(r: AdaptedRead, w: AdaptedWrite, buffer: usize) -> Self

Trait Implementations

impl NonBlockingStream for NonBlockingStreamAdapter

fn try_recv(&mut self) -> Result<Bytes, TransportError>

fn try_send(&mut self, data: Option<Bytes>) -> Result<bool, TransportError>

fn source(&mut self) -> IOSource<'_>

fn shutdown(&mut self, how: Shutdown) -> Result<()>