Trait StreamSource 

pub trait StreamSource {
    type Item;

    // Required method
    fn next_item(&mut self) -> Option<Self::Item>;
}

The dyn-compatible core trait for streams.

Implement this for any type that produces a sequence of values. Unlike Stream (which requires Self: Sized), StreamSource can be used as a trait object (Box<dyn StreamSource<Item = T>>).

Required Associated Types

type Item

The type of items produced.

Required Methods

fn next_item(&mut self) -> Option<Self::Item>

Advance the stream and return the next item, or None when exhausted.

Dyn Compatibility

This trait is dyn compatible.

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

Implementors

impl<'a, S: StreamSource> StreamSource for ByRefStream<'a, S>

type Item = <S as StreamSource>::Item

impl<A: StreamSource, B: StreamSource> StreamSource for ZipStream<A, B>

type Item = (<A as StreamSource>::Item, <B as StreamSource>::Item)

impl<I: Iterator> StreamSource for InfiniteStream<I>

type Item = <I as Iterator>::Item

impl<S: StreamSource, P: FnMut(&S::Item) -> bool> StreamSource for FilterStream<S, P>

type Item = <S as StreamSource>::Item

impl<S: StreamSource, U, F: FnMut(S::Item) -> U> StreamSource for MapStream<S, F>

type Item = U

impl<S: StreamSource> StreamSource for FlattenStream<S>

where S::Item: IntoIterator,

type Item = <<S as StreamSource>::Item as IntoIterator>::Item

impl<S: StreamSource> StreamSource for SkipStream<S>

type Item = <S as StreamSource>::Item

impl<S: StreamSource> StreamSource for TakeStream<S>

type Item = <S as StreamSource>::Item

impl<S: StreamSource> StreamSource for WindowedStream<S>

where S::Item: Clone,

type Item = Vec<<S as StreamSource>::Item>

impl<T: Send + 'static> StreamSource for MergeStream<T>

type Item = T

impl<T> StreamSource for BoxedStream<T>

type Item = T