Struct tokio_simplified::IoManager

pub struct IoManager<SendType, ReceiveType = SendType> { /* fields omitted */ }

A simplified interface to interact with tokio's streams and sinks.

Allows easy subscription to the stream's frames, and easy sending to the sink.

Methods

impl<SendType, ReceiveType> IoManager<SendType, ReceiveType>

pub fn subscribe_mpsc_sender(&self, subscriber: Sender<ReceiveType>) -> u32

subscriber will receive any data polled from the internal stream.

pub fn on_receive<F>(&self, callback: F) -> u32 where
    F: FnMut(ReceiveType) -> Result<(), ()> + Send + 'static,
    ReceiveType: Send + 'static, 

callback will be called for each frame polled from the internal stream.

pub fn extract_callback(&self, key: &u32) -> Option<Sender<ReceiveType>>

Removes the callback with keyhandle. key should be a value returned by either on_receive() or subscribe_mpsc_sender().

Returns the mpsc::Sender that used to be notified upon new frames, just in case.

pub fn get_writer(&self) -> IoWriter<SendType>

Returns an IoWriter that will forward data to the associated tokio sink.

Trait Implementations

impl<SendType: Clone, ReceiveType: Clone> Clone for IoManager<SendType, ReceiveType>

fn clone(&self) -> IoManager<SendType, ReceiveType>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.