Struct sea_streamer_file::FileConsumer
source · pub struct FileConsumer { /* private fields */ }
Implementations§
Trait Implementations§
source§impl Consumer for FileConsumer
impl Consumer for FileConsumer
source§async fn seek(&mut self, ts: Timestamp) -> FileResult<()>
async fn seek(&mut self, ts: Timestamp) -> FileResult<()>
Affects all streams. If the consumer is subscribing to multiple streams, it will be sought by the first stream key. It revokes the group membership of the Consumer.
source§async fn rewind(&mut self, to: SeqPos) -> FileResult<()>
async fn rewind(&mut self, to: SeqPos) -> FileResult<()>
Affects all streams. If the consumer is subscribing to multiple streams, it will be sought by the first stream key. It revokes the group membership of the Consumer.
source§fn assign(&mut self, _: (StreamKey, ShardId)) -> FileResult<()>
fn assign(&mut self, _: (StreamKey, ShardId)) -> FileResult<()>
Currently unimplemented; always error.
source§fn unassign(&mut self, _: (StreamKey, ShardId)) -> FileResult<()>
fn unassign(&mut self, _: (StreamKey, ShardId)) -> FileResult<()>
Currently unimplemented; always error.
source§fn next(&self) -> Self::NextFuture<'_>
fn next(&self) -> Self::NextFuture<'_>
If there is already a message in the buffer, it yields immediately. Otherwise it will await the next message.
type Error = FileErr
type Message<'a> = SharedMessage
type NextFuture<'a> = NextFuture<'a>
type Stream<'a> = StreamFuture<'a>
source§impl Debug for FileConsumer
impl Debug for FileConsumer
Auto Trait Implementations§
impl Freeze for FileConsumer
impl RefUnwindSafe for FileConsumer
impl Send for FileConsumer
impl Sync for FileConsumer
impl Unpin for FileConsumer
impl UnwindSafe for FileConsumer
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