Struct ChannelSource 

pub struct ChannelSource<T> { /* private fields */ }

Available on crate feature std only.

Source adapter over an std::sync::mpsc::Receiver.

pull returns Ok(None) when the channel is empty AND all senders have been dropped.

Implementations

impl<T> ChannelSource<T>

pub fn new(rx: Receiver<T>) -> Self

Wrap a receiver into a source.

Trait Implementations

impl<T> Source for ChannelSource<T>

where T: 'static,

type Item = T

Type of item produced.

type Error = Infallible

Error type the source can return.

fn pull(&mut self) -> Result<Option<Self::Item>, Self::Error>

Pull the next item.

fn close(&mut self) -> Result<(), Self::Error>

Close the source. Default impl does nothing.