Struct sharded_thread::mesh::MeshBuilder

pub struct MeshBuilder<T> {
    pub channels: Vec<Arc<SharedQueueThreaded<T>>>,
    pub shared_joined: Arc<AtomicUsize>,
    /* private fields */
}

A Mesh is a structure which can be shared in every thread by reference to allow threads to join the Mesh and talk to each others.

Fields

channels: Vec<Arc<SharedQueueThreaded<T>>>

shared_joined: Arc<AtomicUsize>

Implementations

impl<T> MeshBuilder<T>

pub fn new() -> Result<Self>

Create a new mesh

pub fn join_with(&self, peer: usize) -> Result<Shard<T>>

Join the mesh means you can talk to other peer and peer can talk to you.

You must assign yourself an id so other Shard will be able to talk with you using this ID