ruststream 0.7.5

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.
Documentation 
1
2
3
4
5
6
7
8
9

use ruststream::subscriber;

// No thread at all is not a policy.
#[subscriber("orders", threads(0))]
async fn handle(order: &u8) {
    let _ = order;
}

fn main() {}