Struct sea_streamer_file::FileConsumer

pub struct FileConsumer { /* private fields */ }

Implementations

impl FileConsumer

pub fn file_id(&self) -> &FileId

Get the FileId

pub async fn seek_to(&mut self, target: SeekTarget) -> Result<(), FileErr>

Seeking revokes the group membership of the Consumer

Warning: This future must not be canceled.

Trait Implementations

impl Consumer for FileConsumer

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.

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.

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

Currently unimplemented; always error.

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

Currently unimplemented; always error.

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>

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 FileConsumer

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

Formats the value using the given formatter.

impl Drop for FileConsumer

fn drop(&mut self)

Executes the destructor for this type.