nym-task 1.21.1

Task handling
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

// Copyright 2024 - Nym Technologies SA <contact@nymtech.net>
// SPDX-License-Identifier: Apache-2.0

use std::{any::Any, fmt};

pub type SentStatus = Box<dyn TaskStatusEvent>;
pub type StatusSender = futures::channel::mpsc::Sender<SentStatus>;
pub type StatusReceiver = futures::channel::mpsc::Receiver<SentStatus>;

pub trait TaskStatusEvent: Send + Sync + Any + fmt::Display {
    fn as_any(&self) -> &dyn Any;
}

#[derive(Debug, PartialEq, Eq)]
pub enum TaskStatus {
    Ready,
    ReadyWithGateway(String),
}

impl fmt::Display for TaskStatus {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            TaskStatus::Ready => write!(f, "Ready"),
            TaskStatus::ReadyWithGateway(gateway) => {
                write!(f, "Ready and connected to gateway: {gateway}")
            }
        }
    }
}

impl TaskStatusEvent for TaskStatus {
    fn as_any(&self) -> &dyn Any {
        self
    }
}