Struct dcl_rpc::stream_protocol::Generator

pub struct Generator<M>(_);

Generator struct contains only one field which it’s an unbounded receiver from unounded channel from tokio crate

The other half of the unbounded channel is given to the GeneratorYielder

Implementations

impl<M: Send + Sync + 'static> Generator<M>

pub fn create() -> (Self, GeneratorYielder<M>)

Creates an unbounded channel and returns a Generator and GeneratorYielder

pub fn from_generator<O: Send + Sync + 'static, F: Fn(M) -> O + Send + Sync + 'static>( old_generator: Generator<M>, transformer: F ) -> Generator<O>

pub async fn next(&mut self) -> Option<M>

pub fn close(&mut self)