rskit-worker 0.2.0-alpha.2

Task worker pool with JoinSet, typed events, and provider bridges
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

use tokio::sync::mpsc;
use tokio_util::sync::CancellationToken;

use rskit_errors::AppResult;

use crate::event::Event;

/// Core trait for worker task handlers.
///
/// Implementors receive a task `I`, an event sender for streaming intermediate results,
/// and a cancellation token for cooperative cancellation.
#[async_trait::async_trait]
pub trait Handler<I, O>: Send + Sync
where
    I: Send + 'static,
    O: Send + Clone + 'static,
{
    /// Execute the task, emitting intermediate events via `emit` and
    /// honouring cancellation requests via `cancel`.
    async fn handle(
        &self,
        task: I,
        emit: mpsc::Sender<Event<O>>,
        cancel: CancellationToken,
    ) -> AppResult<O>;
}