Struct simple_message_channels::Writer

pub struct Writer<W> { /* fields omitted */ }

A writer for SMC messages.

Consumes an futures::io::AsyncWrite to which messages will be written.

Methods

impl<W> Writer<W> where
    W: AsyncWrite + Unpin, 

pub fn new(writer: W) -> Self

Create a new message writer.

pub async fn send<'_>(&'_ mut self, message: Message) -> Result<(), Error>

Send a message.

This encodes the message, writes it and flushes the writer.

pub async fn send_batch<'_>(
    &'_ mut self,
    messages: Vec<Message>
) -> Result<(), Error>

Send a batch of messages.

This works like Writer::send but flushes after all messages are written.