Struct sea_streamer_stdio::StdioStreamer

pub struct StdioStreamer { /* private fields */ }

Trait Implementations

impl Clone for StdioStreamer

fn clone(&self) -> StdioStreamer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StdioStreamer

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

Formats the value using the given formatter.

impl Default for StdioStreamer

fn default() -> StdioStreamer

Returns the “default value” for a type.

impl Streamer for StdioStreamer

async fn connect( _: StreamerUri, options: Self::ConnectOptions ) -> StdioResult<Self>

Nothing will happen until you create a producer/consumer

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

Call this method if you want to exit gracefully. This waits asynchronously until all pending messages are sent.

The side effects is global: all existing consumers and producers will become unusable, until you connect again.

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

A background thread will be spawned to read stdin dedicatedly. It is safe to spawn multiple consumers.

type Error = StdioErr

type Producer = StdioProducer

type Consumer = StdioConsumer

type ConnectOptions = StdioConnectOptions

type ConsumerOptions = StdioConsumerOptions

type ProducerOptions = StdioProducerOptions

async fn create_generic_producer( &self, _: Self::ProducerOptions ) -> StdioResult<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.