Struct FileSubscriber 

pub struct FileSubscriber { /* private fields */ }

A subscription to one stream key in the file; yields SeaMessages.

Dropping the subscriber stops the driver task. A replay subscription completes (the stream ends) at the end of the file.

Implementations

impl FileSubscriber

pub fn stream_key(&self) -> &str

The stream key this subscription consumes.

Trait Implementations

impl Debug for FileSubscriber

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

Formats the value using the given formatter.

impl Seekable for FileSubscriber

type Seeker = FileSeeker

The handle usable while this subscriber’s stream is running.

fn seeker(&self) -> FileSeeker

Mints a handle for repositioning this subscription.

impl Subscriber for FileSubscriber

type Message = SeaMessage

The message type yielded by this subscriber.

type Error = SeaFileError

The error type yielded by the stream when delivery fails.

fn stream( &mut self, ) -> impl Stream<Item = Result<SeaMessage, SeaFileError>> + Send + '_

Returns a stream of broker deliveries.