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

fn connect<'async_trait>( uri: StreamerUri, options: Self::ConnectOptions ) -> Pin<Box<dyn Future<Output = FileResult<Self>> + Send + 'async_trait>>where Self: 'async_trait,

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

fn disconnect<'async_trait>( self ) -> Pin<Box<dyn Future<Output = FileResult<()>> + Send + 'async_trait>>where Self: 'async_trait,

End the producers before disconnecting.

type Error = FileErr

type Producer = FileProducer

type Consumer = FileConsumer

type ConnectOptions = FileConnectOptions

type ConsumerOptions = FileConsumerOptions

type ProducerOptions = FileProducerOptions

fn create_generic_producer<'life0, 'async_trait>( &'life0 self, options: Self::ProducerOptions ) -> Pin<Box<dyn Future<Output = FileResult<Self::Producer>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Create a producer that can stream to any stream key.

fn create_consumer<'life0, 'life1, 'async_trait>( &'life0 self, streams: &'life1 [StreamKey], options: Self::ConsumerOptions ) -> Pin<Box<dyn Future<Output = FileResult<Self::Consumer>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a consumer subscribing to the specified streams.

fn create_producer<'life0, 'async_trait>( &'life0 self, stream: StreamKey, options: Self::ProducerOptions ) -> Pin<Box<dyn Future<Output = Result<Self::Producer, StreamErr<Self::Error>>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self: Sync + 'async_trait,

Create a producer that streams to the specified stream.