ruststream 0.4.0

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;

// `batch(..)` wraps exactly one source; it is a marker, not a multi-argument constructor.
#[subscriber(batch("a", "b"))]
async fn handle(orders: &[u8]) {}

fn main() {}