Struct RecieverStream 

pub struct RecieverStream { /* private fields */ }

Implementations

impl RecieverStream

pub fn new(inner: AsyncReceiver<Message>) -> Self

pub fn new_timed( inner: AsyncReceiver<Message>, timeout: Option<Duration>, ) -> Self

pub fn to_stream(&self) -> impl Stream<Item = CoreResult<Message>> + '_

pub fn to_stream_static( self: Arc<Self>, ) -> impl Stream<Item = CoreResult<Message>> + 'static