Struct dynamo_subscriber::stream::ConsumerChannel

pub struct ConsumerChannel { /* private fields */ }

Communication channel half to the stream.

Using this channel, you can do the following.

• Confirm that the stream is ready to polling or not.
• Send Stop polling event to the stream.

Implementations

impl ConsumerChannel

pub fn close(&mut self, f: impl FnOnce())

Send Stop polling event to the stream. The passed closure is executed only when sending event fails.

pub fn initialized(&mut self) -> bool

Return true if the stream is ready to polling.

Trait Implementations

impl Debug for ConsumerChannel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.