ruststream 0.7.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

use ruststream::subscriber;

// A subscriber has at most one reply destination; a second `reply(..)` is rejected.
#[subscriber("orders", reply("a"), reply("b"))]
async fn handle(order: &u8) {}

fn main() {}