Trait Stream 

pub trait Stream<ITEM> {
    // Required method
    fn next(&mut self) -> impl Future<Output = Option<ITEM>> + Send;
}

A stream.

Required Methods

fn next(&mut self) -> impl Future<Output = Option<ITEM>> + Send

Returns next item.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors

impl Stream<Result<OwnedMessage, KafkaError>> for KafkaStreamConsumerAdapter

Available on crate feature kafka only.

impl<ITEM, STREAM: StreamExt<Item = ITEM> + Send + Unpin> Stream<ITEM> for STREAM