ave-core 0.11.0

Averiun Ledger core runtime and node API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

//! # Helper service
//!

use ave_actors::ActorError;
use ave_network::CommandHelper as Command;
use tokio::sync::mpsc::Sender;
use tracing::error;

use super::NetworkMessage;

/// The Helper service.
#[derive(Debug, Clone)]
pub struct NetworkSender {
    /// The command sender to communicate with the worker.
    command_sender: Sender<Command<NetworkMessage>>,
}

impl NetworkSender {
    /// Create a new `NetworkSender`.
    pub const fn new(command_sender: Sender<Command<NetworkMessage>>) -> Self {
        Self { command_sender }
    }

    /// Send command to the network worker.
    pub async fn send_command(
        &self,
        command: Command<NetworkMessage>,
    ) -> Result<(), ActorError> {
        self.command_sender.send(command).await.map_err(|e| {
            error!(
                error = %e,
                "Failed to send command to network worker"
            );
            ActorError::Functional {
                description: e.to_string(),
            }
        })
    }

    /// Send a message to the Helper worker.
    pub fn sender(&self) -> Sender<Command<NetworkMessage>> {
        self.command_sender.clone()
    }
}