Struct OwnerChangedStream

pub struct OwnerChangedStream<'a> { /* private fields */ }

A stream::Stream implementation that yields UniqueName when the bus owner changes.

Use Proxy::receive_owner_changed to create an instance of this type.

Implementations

impl<'a> OwnerChangedStream<'a>

pub fn name(&self) -> &BusName<'a>

The bus name being tracked.

Trait Implementations

impl OrderedStream for OwnerChangedStream<'_>

type Data = Option<UniqueName<'static>>

The unordered data carried by this stream

type Ordering = Sequence

The type ordered by this stream.

fn poll_next_before( self: Pin<&mut Self>, cx: &mut Context<'_>, before: Option<&Self::Ordering>, ) -> Poll<PollResult<Self::Ordering, Self::Data>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if needed, and returning NoneBefore if it is known that the stream will not produce any more values ordered before the given point.

fn position_hint(&self) -> Option<MaybeBorrowed<'_, Self::Ordering>>

The minimum value of the ordering for any future items.

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

Returns the bounds on the remaining length of the stream.

impl Stream for OwnerChangedStream<'_>

type Item = Option<UniqueName<'static>>

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.