Trait Messages 

pub trait Messages<T, Message, Error>
where
    Self: Sized,
{
    // Required method
    fn messages_with_error_callback<F>(
        self,
        error_callback: F,
    ) -> MessageStream<Self, F>
       where F: FnMut(Error);

    // Provided method
    fn messages(self) -> MessageStream<Self, fn(Error)> { ... }
}

Utility trait for creating message stream with filtered-out errors.

Required Methods

fn messages_with_error_callback<F>( self, error_callback: F, ) -> MessageStream<Self, F>

where F: FnMut(Error),

Message stream with filtered-out errors.

Calls a callback when error occurs.

Provided Methods

fn messages(self) -> MessageStream<Self, fn(Error)>

Message stream with filtered-out errors.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<T, Message, Error> Messages<T, Message, Error> for T

where T: Stream<Item = Result<Message, Error>> + Unpin,