Struct SeaProducer 

pub struct SeaProducer { /* private fields */ }

sea-streamer-socket concrete type of Producer.

Trait Implementations

impl Clone for SeaProducer

fn clone(&self) -> SeaProducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SeaProducer

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

Formats the value using the given formatter.

impl From<StdioProducer> for SeaProducer

fn from(i: StdioProducer) -> Self

Converts to this type from the input type.

impl Producer for SeaProducer

type Error = BackendErr

type SendFuture = SendFuture

fn send_to<S: Buffer>( &self, stream: &StreamKey, payload: S, ) -> StreamResult<Self::SendFuture, BackendErr>

Send a message to a particular stream. This function is non-blocking. You don’t have to await the future if you are not interested in the Receipt.

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

End this producer, only after flushing all it’s pending messages.

async fn flush(&mut self) -> StreamResult<(), BackendErr>

Flush all pending messages.

fn anchor(&mut self, stream: StreamKey) -> StreamResult<(), BackendErr>

Lock this producer to a particular stream. This function can only be called once. Subsequent calls should return StreamErr::AlreadyAnchored error.

fn anchored(&self) -> StreamResult<&StreamKey, BackendErr>

If the producer is already anchored, return a reference to the StreamKey. If the producer is not anchored, this will return StreamErr::NotAnchored error.

fn send<S>( &self, payload: S, ) -> Result<Self::SendFuture, StreamErr<Self::Error>>

where S: Buffer,

Send a message to the already anchored stream. This function is non-blocking. You don’t have to await the future if you are not interested in the Receipt.

impl SeaStreamerBackend for SeaProducer

type Stdio = StdioProducer

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