Trait StreamExt 

pub trait StreamExt: Stream {
    // Provided method
    fn fork(self) -> Forked<Self>
       where Self: Sized,
             Self::Item: Clone { ... }
}

An extension trait that enables Streams to be forked.

Provided Methods

fn fork(self) -> Forked<Self>

where Self: Sized, Self::Item: Clone,

Turns a steam into a cloneable stream. Polled items are cached and cloned.

This method consumes the source stream and returns its wrapped version.

Implementors

impl<S> StreamExt for S

where S: Stream,