Trait StreamExt 

pub trait StreamExt: Stream {
    // Provided methods
    fn chain_infinite<B: InfiniteStream<Item = Self::Item>>(
        self,
        second: B,
    ) -> Chain<Self, B>
       where Self: Sized { ... }
    fn chain_pending(self) -> Chain<Self, Pending<Self::Item>>
       where Self: Sized { ... }
    fn expect(self, msg: &str) -> Expect<'_, Self>
       where Self: Sized { ... }
}

Provided Methods

fn chain_infinite<B: InfiniteStream<Item = Self::Item>>( self, second: B, ) -> Chain<Self, B>

where Self: Sized,

fn chain_pending(self) -> Chain<Self, Pending<Self::Item>>

where Self: Sized,

Shorthand for .chain_infinite(infinite_stream::pending()).

fn expect(self, msg: &str) -> Expect<'_, Self>

where Self: Sized,

Dyn Compatibility

This trait is dyn compatible.

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

Implementors

impl<T: Stream + ?Sized> StreamExt for T