ruststream 0.7.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: expected `Type::new(..)`: the path must name a type and an associated constructor - a free function does not expose its type to the macro
  --> tests/ui/subscriber_source_free_function.rs:15:14
   |
15 | #[subscriber(stream("orders"))]
   |              ^^^^^^

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