Struct simple_message_channels::Reader

pub struct Reader<R> { /* fields omitted */ }

A reader for SMC messages.

Takes any futures::io::AsyncRead and is a async_std::stream::Stream of Messages.

Example

use simple_message_channels::Reader;
let stdin = io::stdin().lock().await;
let mut reader = Reader::new(stdin);
while let Some(msg) = reader.next().await {
    let msg = msg?;
    println!("Received: ch {} typ {} msg {:?}", msg.channel, msg.typ, text);
}

Methods

impl<R> Reader<R> where
    R: AsyncRead + Send + Unpin + 'static, 

pub fn new(reader: R) -> Self

Create a new message reader from any async_std::io::Read.

Trait Implementations

impl<R> Stream for Reader<R> where
    R: AsyncRead + Send + Unpin + 'static, 

type Item = Result<Message, Error>

Values yielded by the stream.

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context
) -> Poll<Option<Result<Message, Error>>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.