ruststream 0.5.2

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.
Documentation
1
2
3
4
5
error: expected `publish("reply-topic")`, `workers(n[, by_key])`, or `on_failure(panic = .., decode = ..)`
 --> tests/ui/subscriber_unknown_clause.rs:4:24
  |
4 | #[subscriber("orders", frobnicate)]
  |                        ^^^^^^^^^^