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§async fn seek(&mut self, _: Timestamp) -> StdioResult<()>
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
. Read moresource§async fn rewind(&mut self, _: SeqPos) -> StdioResult<()>
async fn rewind(&mut self, _: SeqPos) -> StdioResult<()>
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.
This method can be called from multiple threads.
source§impl Debug for StdioConsumer
impl Debug for StdioConsumer
Auto Trait Implementations§
impl Freeze for StdioConsumer
impl RefUnwindSafe for StdioConsumer
impl Send for StdioConsumer
impl Sync for StdioConsumer
impl Unpin for StdioConsumer
impl UnwindSafe for StdioConsumer
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more