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.

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.

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

Create a consumer subscribing to the specified streams.

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.