Trait InfiniteStreamExt 

pub trait InfiniteStreamExt: InfiniteStream {
    // Provided methods
    fn next(&mut self) -> Next<'_, Self>
       where Self: Unpin { ... }
    fn boxed<'a>(
        self,
    ) -> Pin<Box<dyn InfiniteStream<Item = Self::Item> + Send + 'a>>
       where Self: Send + Sized + 'a { ... }
    fn filter<Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut>(
        self,
        f: F,
    ) -> Filter<Self, Fut, F>
       where Self: Sized { ... }
    fn filter_map<T, Fut: Future<Output = Option<T>>, F: FnMut(Self::Item) -> Fut>(
        self,
        f: F,
    ) -> FilterMap<Self, Fut, F>
       where Self: Sized { ... }
    fn left_stream<B: InfiniteStream<Item = Self::Item>>(
        self,
    ) -> Either<Self, B>
       where Self: Sized { ... }
    fn map<T, F: FnMut(Self::Item) -> T>(self, f: F) -> Map<Self, F>
       where Self: Sized { ... }
    fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Self::Item>
       where Self: Unpin { ... }
    fn right_stream<A: InfiniteStream<Item = Self::Item>>(
        self,
    ) -> Either<A, Self>
       where Self: Sized { ... }
    fn then<T, Fut: Future<Output = T>, F: FnMut(Self::Item) -> Fut>(
        self,
        f: F,
    ) -> Then<Self, Fut, F>
       where Self: Sized { ... }
}

Provided Methods

fn next(&mut self) -> Next<'_, Self>

where Self: Unpin,

fn boxed<'a>( self, ) -> Pin<Box<dyn InfiniteStream<Item = Self::Item> + Send + 'a>>

where Self: Send + Sized + 'a,

fn filter<Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut>( self, f: F, ) -> Filter<Self, Fut, F>

where Self: Sized,

fn filter_map<T, Fut: Future<Output = Option<T>>, F: FnMut(Self::Item) -> Fut>( self, f: F, ) -> FilterMap<Self, Fut, F>

where Self: Sized,

fn left_stream<B: InfiniteStream<Item = Self::Item>>(self) -> Either<Self, B>

where Self: Sized,

fn map<T, F: FnMut(Self::Item) -> T>(self, f: F) -> Map<Self, F>

where Self: Sized,

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

where Self: Unpin,

fn right_stream<A: InfiniteStream<Item = Self::Item>>(self) -> Either<A, Self>

where Self: Sized,

fn then<T, Fut: Future<Output = T>, F: FnMut(Self::Item) -> Fut>( self, f: F, ) -> Then<Self, Fut, F>

where Self: Sized,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<T: InfiniteStream + ?Sized> InfiniteStreamExt for T