Type Alias sea_streamer_kafka::NextFuture

pub type NextFuture<'a> = Map<StreamFuture<MessageStream<'a, DefaultConsumerContext>>, fn(_: (Option<Result<BorrowedMessage<'a>, KafkaErr>>, MessageStream<'a, DefaultConsumerContext>)) -> KafkaResult<KafkaMessage<'a>>>;

Concrete type of Future that will yield the next message.

Aliased Type

struct NextFuture<'a> { /* private fields */ }