Struct truba::continuous_stream::ContinuousStream

pub struct ContinuousStream<S> { /* private fields */ }

Implementations

impl<S> ContinuousStream<S>

pub fn new(stream: S) -> Self

pub fn set(&mut self, stream: S)

pub fn clear(&mut self)

pub fn is_empty(&self) -> bool

pub fn get_mut(&mut self) -> Option<&mut S>

pub async fn recv(&mut self) -> Option<S::Item>where S: Stream + Unpin,

Trait Implementations

impl<S: Default> Default for ContinuousStream<S>

fn default() -> ContinuousStream<S>

Returns the “default value” for a type.