Struct DirectCommunicators 

pub struct DirectCommunicators<I: Invocation> { /* private fields */ }

Implementations

impl<I: Invocation> DirectCommunicators<I>

pub fn new() -> Self

pub fn with_characteristics(packet_loss: f32, e2e_delay: Normal<f32>) -> Self

pub async fn set_packet_loss( &mut self, from: NodeIdOf<I>, to: NodeIdOf<I>, packet_loss: f32, )

pub async fn set_delay( &mut self, from: NodeIdOf<I>, to: NodeIdOf<I>, delay: Normal<f32>, )

pub async fn register(&self, node_id: NodeIdOf<I>, handler: RequestHandler<I>)

pub fn events(&self) -> impl Stream<Item = DirectCommunicatorEvent<I>>

pub fn create_communicator_for( &self, node_id: NodeIdOf<I>, ) -> DirectCommunicator<I>

Trait Implementations

impl<I: Invocation> Clone for DirectCommunicators<I>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I: Debug + Invocation> Debug for DirectCommunicators<I>

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

Formats the value using the given formatter.

impl<I: Invocation> Default for DirectCommunicators<I>

fn default() -> Self

Returns the “default value” for a type.