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
14
15

use ruststream::{Outgoing, subscriber};
use serde::Serialize;

#[derive(Serialize, Outgoing)]
struct Receipt;

// `reply(..)` takes the reply topic as a string literal or a `&'static str` expression; an
// integer fails the destination's type.
#[subscriber("orders", reply(123))]
async fn handle(order: &u8) -> Receipt {
    let _ = order;
    Receipt
}

fn main() {}