Struct zbus::fdo::InterfacesAddedStream

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

A Stream implementation that yields InterfacesAdded signals.

Use ObjectManagerProxy::receive_interfaces_added to create an instance of this type.

Implementations

impl<'a> InterfacesAddedStream<'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 InterfacesAddedStream<'_>

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 InterfacesAddedStream<'a>

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

Formats the value using the given formatter.

impl<'a> Deref for InterfacesAddedStream<'a>

type Target = SignalStream<'a>

The resulting type after dereferencing.

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

Dereferences the value.

impl DerefMut for InterfacesAddedStream<'_>

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

Mutably dereferences the value.

impl FusedStream for InterfacesAddedStream<'_>

fn is_terminated(&self) -> bool

Returns true if the stream should no longer be polled.

impl OrderedStream for InterfacesAddedStream<'_>

type Data = InterfacesAdded

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

type Item = InterfacesAdded

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.