Struct sea_streamer_socket::SeaStreamer

pub struct SeaStreamer { /* private fields */ }

sea-streamer-socket concrete type of Streamer.

Trait Implementations

impl Debug for SeaStreamer

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

Formats the value using the given formatter.

impl From<StdioStreamer> for SeaStreamer

fn from(i: StdioStreamer) -> Self

Converts to this type from the input type.

impl SeaStreamerBackend for SeaStreamer

type Stdio = StdioStreamer

fn backend(&self) -> Backend

Identifies the underlying backend

fn get_stdio(&mut self) -> Option<&mut Self::Stdio>

Get the concrete type for the Stdio backend. None if it’s another Backend

impl Streamer for SeaStreamer

type Error = BackendErr

type Producer = SeaProducer

type Consumer = SeaConsumer

type ConnectOptions = SeaConnectOptions

type ConsumerOptions = SeaConsumerOptions

type ProducerOptions = SeaProducerOptions

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

Establish a connection to the streaming server.

async fn disconnect(self) -> StreamResult<(), BackendErr>

Flush and disconnect from the streaming server.

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

Create a producer that can stream to any stream key.

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

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.