Struct BusSubscriber

pub struct BusSubscriber<T, S, R>
where
    T: Send + Clone + 'static,
    S: Sink<T> + Unpin,
    R: Stream<Item = T> + Unpin,
{ /* private fields */ }

A receiver of data from a FutureBus. When it is dropped, the sender is removed from the bus. Note that this means dropping a receiver causes a write access to the bus, so it causes a lock.

Implementations

impl<T, S, R> BusSubscriber<T, S, R>

where T: Send + Clone + 'static, S: Sink<T> + Unpin, R: Stream<Item = T> + Unpin,

pub fn try_clone(&self) -> Option<Self>

Attempts to create a new subscriber. Returns None if the underlying bus has since been dropped.

Trait Implementations

impl<T, S, R> Drop for BusSubscriber<T, S, R>

where T: Send + Clone + 'static, S: Sink<T> + Unpin, R: Stream<Item = T> + Unpin,

fn drop(&mut self)

Executes the destructor for this type.

impl<T, S, R> FusedStream for BusSubscriber<T, S, R>

where T: Send + Clone + 'static, S: Sink<T> + Unpin, R: Stream<Item = T> + Unpin,

fn is_terminated(&self) -> bool

Returns true if the stream should no longer be polled.

impl<T, S, R> Stream for BusSubscriber<T, S, R>

where T: Send + Clone + 'static, S: Sink<T> + Unpin, R: Stream<Item = T> + Unpin,

type Item = <R as Stream>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.