Struct IoWriter

pub struct IoWriter<SendType> { /* private fields */ }

A simple interface to interact with a tokio sink.

Should always be constructed by a call to some IoManager’s get_writer().

Implementations

impl<SendType> IoWriter<SendType>

where SendType: Send + 'static,

pub fn new<SinkType>(sink: SinkType) -> Self

where SinkType: Sink<SinkItem = SendType> + Send + 'static,

pub fn write<T: Into<SendType>>(&mut self, frame: T) -> PromiseHandle<()>

Forwards the frame to the tokio sink associated with the IoManager that build this instance.

Examples found in repository

examples/tcp_server.rs (line 57)

fn process_socket(socket: TcpStream) {
    println!("New Client");
    let (sink, stream) = LineCodec.framed(socket).split();
    let trx = IoManagerBuilder::new(sink, stream)
        .with_filter(|frame, writer| {
            if frame.to_lowercase().contains("hello there") {
                writer.write("General Kenobi!".to_string());
                return None;
            }
            Some(frame)
        })
        .with_error_handler(move |error| {
            println!("{}", error);
        })
        .build();
    let mut writer = trx.get_writer();
    trx.on_receive(move |frame| {
        println!("Got frame: {}", frame);
        writer.write("Hi there".to_string());
        Ok(())
    });
}

Trait Implementations

impl<SendType> Clone for IoWriter<SendType>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.