Crate event_source
source ·Expand description
EventSource
Zero cost non buffered async event emitter
This crate is no_std
Features
- Non buffered, immediate event dispatch
- Zero cost listener adding, removing
- Higher kinded event type
- Propagation control
Example
ⓘ
async fn main() {
let source: Arc<EventSource!(&mut i32)> = Arc::new(EventSource::new());
// imaginary function for spawning future in another thread
spawn({
let source = source.clone();
async {
let mut a = 35;
emit!(source, &mut a);
}
});
let mut output = 0;
// Closure can contain reference!
source.on(|value, flow| {
println!("Event emiited with value: {}!", value);
output = *value;
// mark listener as finished
flow.set_done();
}).await;
println!("Output: {}", output);
}
Output
Event emiited with value: 35!
Output: 35
License
MIT
Macros
- Higher kinded type helper for
EventSource
- Emit event. As methods can’t do mutable reborrowing correctly, you should use this macro.
Structs
- Control current listener’s behaviour
- Struct for emitting values for each listeners
- Future created with
EventSource::on
- Event source