sealrs 0.13.2

Set of classic asynchronous primitives (Actors, Executors, Futures / Promises)
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

//! Wrapper for dispatcher which permits to him mimic to an executor

use crate::common::tsafe::TSafe;
use crate::actors::dispatcher::Dispatcher;
use crate::executors::executor::{Executor, ExecutorTask};
use std::any::Any;

pub struct WrappedDispatcher {
    dispatcher: TSafe<Dispatcher + Send>
}

impl WrappedDispatcher {
    pub fn new(dispatcher: TSafe<Dispatcher + Send>) -> WrappedDispatcher {
        WrappedDispatcher {
            dispatcher
        }
    }
}

impl Executor for WrappedDispatcher {
    fn execute(&mut self, f: ExecutorTask, options: Option<Box<Any>>) {
        self.dispatcher.lock().unwrap().execute(f, options)
    }

    fn stop(&mut self) {
        self.dispatcher.lock().unwrap().stop()
    }
}