Struct IoManager

Source

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

Expand description

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.

Implementations§

Source §

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

Source

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

subscriber will receive any data polled from the internal stream.

Source

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.

Examples found in repository ?

examples/tcp_server.rs (lines 67-71)

51fn process_socket(socket: TcpStream) {
52    println!("New Client");
53    let (sink, stream) = LineCodec.framed(socket).split();
54    let trx = IoManagerBuilder::new(sink, stream)
55        .with_filter(|frame, writer| {
56            if frame.to_lowercase().contains("hello there") {
57                writer.write("General Kenobi!".to_string());
58                return None;
59            }
60            Some(frame)
61        })
62        .with_error_handler(move |error| {
63            println!("{}", error);
64        })
65        .build();
66    let mut writer = trx.get_writer();
67    trx.on_receive(move |frame| {
68        println!("Got frame: {}", frame);
69        writer.write("Hi there".to_string());
70        Ok(())
71    });
72}

Source

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.

Source

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

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

Examples found in repository ?

examples/tcp_server.rs (line 66)

51fn process_socket(socket: TcpStream) {
52    println!("New Client");
53    let (sink, stream) = LineCodec.framed(socket).split();
54    let trx = IoManagerBuilder::new(sink, stream)
55        .with_filter(|frame, writer| {
56            if frame.to_lowercase().contains("hello there") {
57                writer.write("General Kenobi!".to_string());
58                return None;
59            }
60            Some(frame)
61        })
62        .with_error_handler(move |error| {
63            println!("{}", error);
64        })
65        .build();
66    let mut writer = trx.get_writer();
67    trx.on_receive(move |frame| {
68        println!("Got frame: {}", frame);
69        writer.write("Hi there".to_string());
70        Ok(())
71    });
72}