nexus-acto-rs 0.4.2

A Rust crate for Actors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use crate::log::log::LogLevel;
use crate::log::log_event_handler::LogEventHandler;
use crate::log::log_event_stream::LogEventStream;
use std::sync::atomic::{AtomicI32, AtomicUsize, Ordering};
use std::sync::{Arc, Weak};

#[derive(Debug, Clone)]
pub struct LogSubscription {
  pub(crate) event_stream: Weak<LogEventStream>,
  pub(crate) index: Arc<AtomicUsize>,
  pub(crate) func: LogEventHandler,
  pub(crate) min_level: Arc<AtomicI32>,
}

impl LogSubscription {
  pub fn with_min_level(self: &Arc<Self>, level: LogLevel) -> Arc<Self> {
    self.min_level.store(level as i32, Ordering::Relaxed);
    Arc::clone(self)
  }
}