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;

// There is no decode step under `raw`, so a decode failure policy is meaningless.
#[subscriber("frames", raw, on_failure(decode = drop))]
async fn handle(frame: &[u8]) {}

fn main() {}