ruststream 0.6.1

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;

// `raw` takes one delivery's payload; it does not combine with the batch source form.
#[subscriber(batch("frames"), raw)]
async fn handle(frames: &[u8]) {}

fn main() {}