并行事件发射器

一个事件发射器的实现，它在一个可配置的线程池中并发调用事件监听器回调，使用 Future 通知调用者成功或错误。

由于所有值都必须在线程边界之间传输，所有类型 T 必须是 Send。

此外，所有类型 T 必须是 Any，所以 T: 'static。

用法

[dependencies]
futures = "0.1"
parallel-event-emitter = "0.2.4"

使用 String 作为键的示例

extern crate futures;
extern crate parallel_event_emitter;

use futures::Future;
use parallel_event_emitter::*;

fn main() {
    let mut emitter: ParallelEventEmitter<String> = ParallelEventEmitter::new();

    emitter.add_listener("some event", || {
        println!("Hello, World!");

        Ok(())
    }).unwrap();

    assert_eq!(1, emitter.emit("some event").wait().unwrap());
}

或使用自定义事件类型

extern crate futures;
extern crate parallel_event_emitter;

use futures::Future;
use parallel_event_emitter::*;

#[derive(Debug, Hash, PartialEq, Eq, Clone)]
enum MyEvents {
    EventA,
    EventB,
}

fn main() {
    let mut emitter: ParallelEventEmitter<MyEvents> = ParallelEventEmitter::new();

    emitter.add_listener(MyEvents::EventA, || {
        println!("Hello, World!");

        Ok(())
    }).unwrap();

    assert_eq!(1, emitter.emit(MyEvents::EventA).wait().unwrap());
}

Trace<E> 类型

此crate依赖于trace-error crate，以便在所有错误 Result 上具有简单和轻量级的回溯。

如果您选择不使用它，这对我来说是可以的，只需在所有 Trace<E> 值上调用 .into_error() 即可获取真实错误。

[dependencies.parallel-event-emitter]
version = "0.2.4"
features = ["default", "conservative_impl_trait"] # And maybe integer_atomics

[dependencies.parallel-event-emitter]
version = "0.2.4"
features = ["default", "integer_atomics"] # And maybe conservative_impl_trait