Struct network_clique::mock::MockNetwork

pub struct MockNetwork<D: Data> {
    pub add_connection: Channel<(MockPublicKey, MockAddressingInformation)>,
    pub remove_connection: Channel<MockPublicKey>,
    pub send: Channel<(D, MockPublicKey)>,
    pub next: Channel<D>,
}

Fields

add_connection: Channel<(MockPublicKey, MockAddressingInformation)>

remove_connection: Channel<MockPublicKey>

send: Channel<(D, MockPublicKey)>

next: Channel<D>

Implementations

impl<D: Data> MockNetwork<D>

pub fn new() -> Self

pub async fn close_channels(self)

Trait Implementations

impl<D: Clone + Data> Clone for MockNetwork<D>

fn clone(&self) -> MockNetwork<D>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<D: Data> Default for MockNetwork<D>

fn default() -> Self

Returns the “default value” for a type.

impl<D: Data> Network<MockPublicKey, MockAddressingInformation, D> for MockNetwork<D>

fn add_connection( &mut self, peer: MockPublicKey, address: MockAddressingInformation )

Add the peer to the set of connected peers.

fn remove_connection(&mut self, peer: MockPublicKey)

Remove the peer from the set of connected peers and close the connection.

fn send(&self, data: D, recipient: MockPublicKey)

Send a message to a single peer. This function should be implemented in a non-blocking manner.

fn next<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Option<D>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receive a message from the network. This method’s implementation must be cancellation safe.