ruststream 0.7.5

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
10

use ruststream::subscriber;

// A payload's bytes take a named type: the bare slice spelling is rejected with the derive
// that names the lane.
#[subscriber("frames")]
async fn handle(frame: &[u8]) {
    let _ = frame.len();
}

fn main() {}