ruststream 0.7.2

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
11
12
13

error: headers are per-delivery: a batch pairs each element with its contract - take the batch as `&[Message<H, T>]` and read `element.headers` (`Headers<..>` extraction stays on the single-message forms)
  --> tests/ui/subscriber_headers_batch.rs:18:50
   |
18 | async fn bill(_orders: &[Order], Headers(_meta): Headers<Meta>) -> HandlerOutcome {
   |                                                  ^^^^^^^^^^^^^

warning: unused imports: `HandlerOutcome` and `Headers`
 --> tests/ui/subscriber_headers_batch.rs:1:27
  |
1 | use ruststream::runtime::{HandlerOutcome, Headers};
  |                           ^^^^^^^^^^^^^^  ^^^^^^^
  |
  = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default