Struct sea_streamer_file::FileStreamer

pub struct FileStreamer { /* private fields */ }

Trait Implementations

impl Clone for FileStreamer

fn clone(&self) -> FileStreamer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FileStreamer

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

Formats the value using the given formatter.

impl Streamer for FileStreamer

async fn connect( uri: StreamerUri, options: Self::ConnectOptions, ) -> FileResult<Self>

First check whether the file exists. If not, depending on the options, either create it, or error.

async fn disconnect(self) -> FileResult<()>

End the producers before disconnecting.

async fn create_consumer( &self, streams: &[StreamKey], options: Self::ConsumerOptions, ) -> FileResult<Self::Consumer>

To subscribe to all streams in a file, you can use the magic SEA_STREAMER_WILDCARD stream key. For RealTime consumer only.

type Error = FileErr

type Producer = FileProducer

type Consumer = FileConsumer

type ConnectOptions = FileConnectOptions

type ConsumerOptions = FileConsumerOptions

type ProducerOptions = FileProducerOptions

async fn create_generic_producer( &self, options: Self::ProducerOptions, ) -> FileResult<Self::Producer>

Create a producer that can stream to any stream key.

fn create_producer( &self, stream: StreamKey, options: Self::ProducerOptions, ) -> impl Future<Output = Result<Self::Producer, StreamErr<Self::Error>>> + Send

Create a producer that streams to the specified stream.