Struct SdkSubscription 

pub struct SdkSubscription<M> { /* private fields */ }

Stream used by SDK handles when no typed messages are buffered locally.

Implementations

impl<M> SdkSubscription<M>

pub const fn empty() -> Self

Creates an empty typed subscription stream.

pub const fn error(error: SdkError) -> Self

Creates a subscription stream that surfaces a setup error to the caller.

pub const fn is_empty(&self) -> bool

Returns true when this local subscription has no pending setup error.

Trait Implementations

impl<M> Debug for SdkSubscription<M>

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

Formats the value using the given formatter.

impl<M> Default for SdkSubscription<M>

fn default() -> Self

Returns the “default value” for a type.

impl<M> Stream for SdkSubscription<M>

type Item = Result<M, SdkError>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, context: &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.

impl<M> Unpin for SdkSubscription<M>