Struct StdioConsumer 

pub struct StdioConsumer { /* private fields */ }

Trait Implementations

impl Consumer for StdioConsumer

fn assign(&mut self, (s, _): (StreamKey, ShardId)) -> StdioResult<()>

Always succeed if the stream exists. There is only shard ZERO anyway.

fn unassign(&mut self, _: (StreamKey, ShardId)) -> StdioResult<()>

Always fail. There is only shard ZERO anyway.

type Error = StdioErr

type Message<'a> = SharedMessage

type NextFuture<'a> = MapErr<RecvFut<'a, SharedMessage>, fn(RecvError) -> StreamErr<StdioErr>>

type Stream<'a> = Map<RecvStream<'a, SharedMessage>, fn(SharedMessage) -> Result<SharedMessage, StreamErr<StdioErr>>>

async fn seek(&mut self, _: Timestamp) -> StdioResult<()>

Seek all streams to an arbitrary point in time. It will start consuming from the earliest message with a timestamp later than to.

async fn rewind(&mut self, _: SeqPos) -> StdioResult<()>

Rewind all streams to a particular sequence number.

fn next(&self) -> Self::NextFuture<'_>

Poll and receive one message: it awaits until there are new messages. This method can be called from multiple threads.

fn stream<'a, 'b: 'a>(&'b mut self) -> Self::Stream<'a>

Returns an async stream. You cannot create multiple streams from the same consumer, nor perform any operation while streaming.

impl Debug for StdioConsumer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for StdioConsumer

fn drop(&mut self)

Executes the destructor for this type.