Struct sea_streamer_file::FileConsumer

pub struct FileConsumer { /* private fields */ }

Implementations

impl FileConsumer

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

fn seek<'life0, 'async_trait>( &'life0 mut self, ts: Timestamp ) -> Pin<Box<dyn Future<Output = FileResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

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 rewind<'life0, 'async_trait>( &'life0 mut self, to: SeqPos ) -> Pin<Box<dyn Future<Output = FileResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

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 this future is canceled, a Message might still be read. It will be queued for you to consume on the next next() call, which yields immediately. In a nutshell, cancelling this future does not undo the read, but it will not cause any error.

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.