#async #event #dispatcher #listener #parallel

hey_listen

An event-dispatcher-collection offering async, sync, parallel, and prioritised solutions!

8 releases (4 breaking)

new 0.5.0 Apr 18, 2021
0.4.0 May 5, 2019
0.3.0 May 1, 2019
0.2.1 Dec 6, 2018
0.1.2 Jan 13, 2018

#115 in Concurrency

Download history 8/week @ 2020-12-29 21/week @ 2021-01-05 14/week @ 2021-01-12 22/week @ 2021-01-19 10/week @ 2021-01-26 8/week @ 2021-02-02 20/week @ 2021-02-09 33/week @ 2021-02-16 15/week @ 2021-02-23 12/week @ 2021-03-02 8/week @ 2021-03-09 8/week @ 2021-03-16 31/week @ 2021-03-23 25/week @ 2021-03-30 19/week @ 2021-04-06 46/week @ 2021-04-13

81 downloads per month
Used in danmuji

ISC license

41KB
479 lines

ci-badge docs-badge rust version badge crates.io version

Hey! Listen!

Hey_listen is a collection of event-dispatchers aiming to suit all needs!
Currently covering:

  • Priority dispatch
  • Threadpool dispatch
  • Async dispatch

View the examples-folder on how to use each dispatcher.

Everyone is welcome to contribute, check out the CONTRIBUTING.md for further guidance.

Example

Here is a quick example on how to use the event-dispatcher:

use hey_listen::sync::{
    ParallelDispatcher, ParallelListener, ParallelDispatchResult,
};

#[derive(Clone, Eq, Hash, PartialEq)]
enum Event {
    Variant,
}

struct Listener {}

impl ParallelListener<Event> for Listener {
    fn on_event(&self, _event: &Event) -> Option<ParallelDispatchResult> {
        println!("I'm listening! :)");

        None
    }
}

fn main() {
    let listener = Listener {};
    let mut dispatcher = ParallelDispatcher::<Event>::new(4).expect("Could not construct threadpool");

    dispatcher.add_listener(Event::Variant, listener);
    dispatcher.dispatch_event(&Event::Variant);
}

Installation

Add this to your Cargo.toml:

[dependencies]
hey_listen = "0.5"

Dependencies

~0.4–2MB
~42K SLoC