homestar-runtime 0.3.0

Homestar runtime implementation
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

//! Event utilities.

use crate::{
    channel::{AsyncChannel, AsyncChannelReceiver, AsyncChannelSender},
    event_handler::Event,
    settings,
    worker::WorkerMessage,
};

/// Create an [AsyncChannelSender], [AsyncChannelReceiver] pair for [Event]s.
pub(crate) fn setup_event_channel(
    settings: settings::Node,
) -> (AsyncChannelSender<Event>, AsyncChannelReceiver<Event>) {
    AsyncChannel::with(settings.network.events_buffer_len)
}

/// Create an [AsyncChannelSender], [AsyncChannelReceiver] pair for worker messages.
pub(crate) fn setup_worker_channel(
    settings: settings::Node,
) -> (
    AsyncChannelSender<WorkerMessage>,
    AsyncChannelReceiver<WorkerMessage>,
) {
    AsyncChannel::with(settings.network.events_buffer_len)
}