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
8
9
10
11
12
13

error: start_at(..) needs a position constructor; without the clause the subscription simply opens at the broker's default
  --> tests/ui/subscriber_start_at_empty.rs:11:24
   |
11 | #[subscriber("orders", start_at())]
   |                        ^^^^^^^^

warning: unused import: `ruststream::runtime::HandlerResult`
 --> tests/ui/subscriber_start_at_empty.rs:1:5
  |
1 | use ruststream::runtime::HandlerResult;
  |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  |
  = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default