Trait FutStream 

pub trait FutStream<T>: Stream<Item = (NanoTime, T)> + Send { }

A convenience alias for futures::Stream with items of type (NanoTime, T). used by StreamOperators::consume_async.

Implementors

impl<STRM, T> FutStream<T> for STRM

where STRM: Stream<Item = (NanoTime, T)> + Send,