Struct zbus::fdo::NameLostStream

pub struct NameLostStream<'a>(/* private fields */);

A Stream implementation that yields NameLost signals.

Use DBusProxy::receive_name_lost to create an instance of this type.

Implementations

impl<'a> NameLostStream<'a>

pub fn into_inner(self) -> SignalStream<'a>

Consumes self, returning the underlying zbus::#signal_type.

pub fn inner(&self) -> &SignalStream<'a>

The reference to the underlying zbus::#signal_type.

Methods from Deref<Target = SignalStream<'a>>

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

The signal name.

Trait Implementations

impl AsyncDrop for NameLostStream<'_>

fn async_drop<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait,

Perform the async cleanup.

impl<'a> Debug for NameLostStream<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Deref for NameLostStream<'a>

type Target = SignalStream<'a>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for NameLostStream<'_>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl FusedStream for NameLostStream<'_>

fn is_terminated(&self) -> bool

Returns true if the stream should no longer be polled.

impl OrderedStream for NameLostStream<'_>

type Data = NameLost

The unordered data carried by this stream

type Ordering = MessageSequence

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 NameLostStream<'_>

type Item = NameLost

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.