Struct SpscConsumerStream

Source

pub struct SpscConsumerStream<'a, T, const N: usize> { /* private fields */ }

Available on crate feature futures-stream only.

Expand description

Feature-gated futures_core::Stream wrapper around an SpscConsumer.

Trait Implementations§

Source §

impl<T, const N: usize> Debug for SpscConsumerStream<'_, T, N>

Source §

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

Formats the value using the given formatter. Read more

Source §

impl<T, const N: usize> Stream for SpscConsumerStream<'_, T, N>

Source §

type Item = T

Values yielded by the stream.

Source §

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. Read more

Source §

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

Returns the bounds on the remaining length of the stream. Read more

Auto Trait Implementations§

§

impl<'a, T, const N: usize> !RefUnwindSafe for SpscConsumerStream<'a, T, N>

§

impl<'a, T, const N: usize> !UnwindSafe for SpscConsumerStream<'a, T, N>

§

impl<'a, T, const N: usize> Freeze for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Freeze,

§

impl<'a, T, const N: usize> Send for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Send,

§

impl<'a, T, const N: usize> Sync for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Sync,

§

impl<'a, T, const N: usize> Unpin for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Unpin,

§

impl<'a, T, const N: usize> UnsafeUnpin for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: UnsafeUnpin,

Blanket Implementations§

Source §

impl<T> Any for T
where T: 'static + ?Sized,

Source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

Source §

impl<T> Borrow<T> for T
where T: ?Sized,

Source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

Source §

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source §

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

Source §

impl<T> From<T> for T

Source §

fn from(t: T) -> T

Returns the argument unchanged.

Source §

impl<T, U> Into for T
where U: From<T>,

Source §

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source §

impl<T, U> TryFrom for T
where U: Into<T>,

Source §

type Error = !

The type returned in the event of a conversion error.

Source §

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

Source §

impl<T, U> TryInto for T
where U: TryFrom<T>,

Source §

type Error = >::Error

The type returned in the event of a conversion error.

Source §

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Source §

impl<S, T, E> TryStream for S
where S: Stream<Item = Result<T, E>> + ?Sized,

Source §

type Ok = T

The type of successful values yielded by this future

Source §

type Error = E

The type of failures yielded by this future

Source §

fn try_poll_next( self: Pin<&mut S>, cx: &mut Context<'_>, ) -> Poll<Option<Result<<S as TryStream>::Ok, <S as TryStream>::Error>>>

Poll this TryStream as if it were a Stream. Read more

SpscConsumerStream

Struct SpscConsumerStream

Trait Implementations§

impl<T, const N: usize> Debug for SpscConsumerStream<'_, T, N>

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

impl<T, const N: usize> Stream for SpscConsumerStream<'_, T, N>

type Item = T

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

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

Auto Trait Implementations§

impl<'a, T, const N: usize> !RefUnwindSafe for SpscConsumerStream<'a, T, N>

impl<'a, T, const N: usize> !UnwindSafe for SpscConsumerStream<'a, T, N>

impl<'a, T, const N: usize> Freeze for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Freeze,

impl<'a, T, const N: usize> Send for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Send,

impl<'a, T, const N: usize> Sync for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Sync,

impl<'a, T, const N: usize> Unpin for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Unpin,

impl<'a, T, const N: usize> UnsafeUnpin for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: UnsafeUnpin,

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<S, T, E> TryStream for S
where S: Stream<Item = Result<T, E>> + ?Sized,

type Ok = T

type Error = E

fn try_poll_next( self: Pin<&mut S>, cx: &mut Context<'_>, ) -> Poll<Option<Result<<S as TryStream>::Ok, <S as TryStream>::Error>>>

SpscConsumerStream

Struct SpscConsumerStream Copy item path

Trait Implementations§

impl<T, const N: usize> Debug for SpscConsumerStream<'_, T, N>

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

impl<T, const N: usize> Stream for SpscConsumerStream<'_, T, N>

type Item = T

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

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

Auto Trait Implementations§

impl<'a, T, const N: usize> !RefUnwindSafe for SpscConsumerStream<'a, T, N>

impl<'a, T, const N: usize> !UnwindSafe for SpscConsumerStream<'a, T, N>

impl<'a, T, const N: usize> Freeze for SpscConsumerStream<'a, T, N>where &'a SpscConsumer<T, N>: Freeze,

impl<'a, T, const N: usize> Send for SpscConsumerStream<'a, T, N>where &'a SpscConsumer<T, N>: Send,

impl<'a, T, const N: usize> Sync for SpscConsumerStream<'a, T, N>where &'a SpscConsumer<T, N>: Sync,

impl<'a, T, const N: usize> Unpin for SpscConsumerStream<'a, T, N>where &'a SpscConsumer<T, N>: Unpin,

impl<'a, T, const N: usize> UnsafeUnpin for SpscConsumerStream<'a, T, N>where &'a SpscConsumer<T, N>: UnsafeUnpin,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<S, T, E> TryStream for Swhere S: Stream<Item = Result<T, E>> + ?Sized,

type Ok = T

type Error = E

fn try_poll_next( self: Pin<&mut S>, cx: &mut Context<'_>, ) -> Poll<Option<Result<<S as TryStream>::Ok, <S as TryStream>::Error>>>

Struct SpscConsumerStream

impl<'a, T, const N: usize> Freeze for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Freeze,

impl<'a, T, const N: usize> Send for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Send,

impl<'a, T, const N: usize> Sync for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Sync,

impl<'a, T, const N: usize> Unpin for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: Unpin,

impl<'a, T, const N: usize> UnsafeUnpin for SpscConsumerStream<'a, T, N>
where &'a SpscConsumer<T, N>: UnsafeUnpin,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<S, T, E> TryStream for S
where S: Stream<Item = Result<T, E>> + ?Sized,