Struct Producer 

pub struct Producer { /* private fields */ }

Thread-safe Producer type.

use disk_chan::new to create a new Producer for a channel. This will lock the channel to the process as only one process should own the channel at any time.

Use clone to make copies of the Producer. Note that try_clone also exists but is solely for consistency with the Consumer api and cannot actually fail.

let mut tx = disk_chan::new("foo", 2_u32.pow(24), 1).await?;

tx.send("test").await?;

Implementations

impl Producer

pub async fn try_clone(&self) -> Result<Self, Error>

Clone the Producer. This is actually infallible, but exists to have consistency with the Consumer API.

pub async fn subscribe(&self, group: usize) -> Result<Consumer, Error>

Creates a new Consumer with the given group.

This is thread safe and can be called multiple times with the same group, but it is generally recommend to clone existing consumers.

pub async fn send<V: AsRef<[u8]>>(&mut self, val: V) -> Result<(), Error>

Asynchronously sends a message to the channel.

let mut tx = disk_chan::new("foo", 2_u32.pow(24), 1).await?;

tx.send("test").await?;

Trait Implementations

impl Clone for Producer

fn clone(&self) -> Producer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Producer

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

Formats the value using the given formatter.