ruststream 0.5.2

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;

// A batch publishing handler replies with a `Vec`; a scalar return is rejected.
#[subscriber(batch("orders"), publish("done"))]
async fn handle(orders: &[u8]) -> u8 {
    0
}

fn main() {}