Struct Shard

pub struct Shard<T> { /* private fields */ }

The structure which is used to communicate with other peers from the Mesh.

Implementations

impl<T> Shard<T>

pub fn receiver(&self) -> Option<Receiver<T>>

Take the receiver of this shard. Shard are implemented using mpsc channels, so only one Receiver can receiving values from the other shards.

pub fn send_to(&self, val: T, shard: usize) -> Result<(), SenderError>

Send a value to the proper shard

Fail if this Shard did not join yet.

pub fn send_to_unchecked(&self, val: T, shard: usize)

Send a value to a shard

Trait Implementations

impl<T> Debug for Shard<T>

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

Formats the value using the given formatter.