Struct network_clique::service::ServiceInterface

struct ServiceInterface<PK: PublicKey, D: Data, A: Data> {
    commands_for_service: UnboundedSender<ServiceCommand<PK, D, A>>,
    next_from_service: UnboundedReceiver<D>,
}

Fields

commands_for_service: UnboundedSender<ServiceCommand<PK, D, A>>

next_from_service: UnboundedReceiver<D>

Trait Implementations

impl<PK: PublicKey, D: Data, A: Data> Network<PK, A, D> for ServiceInterface<PK, D, A>

fn add_connection(&mut self, peer: PK, address: A)

Add the peer to the set of connected peers.

fn remove_connection(&mut self, peer: PK)

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

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

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.