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 batch of payloads takes a named element type: both bare batch spellings are rejected with
// the derive that names the lane.
#[subscriber("frames")]
async fn batches(frames: &[&[u8]]) {
    let _ = frames.len();
}

fn main() {}