Struct sea_streamer_stdio::StdioConsumer
source · pub struct StdioConsumer { /* private fields */ }
Trait Implementations§
source§impl Consumer for StdioConsumer
impl Consumer for StdioConsumer
source§fn assign(&mut self, (s, _): (StreamKey, ShardId)) -> StdioResult<()>
fn assign(&mut self, (s, _): (StreamKey, ShardId)) -> StdioResult<()>
Always succeed if the stream exists. There is only shard ZERO anyway.
source§fn unassign(&mut self, _: (StreamKey, ShardId)) -> StdioResult<()>
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>>>
source§fn seek<'life0, 'async_trait>(
&'life0 mut self,
__arg1: Timestamp
) -> Pin<Box<dyn Future<Output = StdioResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn seek<'life0, 'async_trait>( &'life0 mut self, __arg1: Timestamp ) -> Pin<Box<dyn Future<Output = StdioResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Seek all streams to an arbitrary point in time. It will start consuming from the earliest message
with a timestamp later than
to
. Read moresource§fn rewind<'life0, 'async_trait>(
&'life0 mut self,
__arg1: SeqPos
) -> Pin<Box<dyn Future<Output = StdioResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn rewind<'life0, 'async_trait>( &'life0 mut self, __arg1: SeqPos ) -> Pin<Box<dyn Future<Output = StdioResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Rewind all streams to a particular sequence number. Read more
source§fn next(&self) -> Self::NextFuture<'_>
fn next(&self) -> Self::NextFuture<'_>
Poll and receive one message: it awaits until there are new messages