ruststream 0.7.0-rc.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
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use ruststream::runtime::{HandlerOutcome, Out};
use ruststream::{OutSlot, Outgoing, Publisher, subscriber};
use serde::{Deserialize, Serialize};

#[derive(Deserialize)]
struct Order {
    id: u32,
}

#[derive(Serialize, Deserialize)]
struct DoneMeta {
    task_id: u64,
}

#[derive(Outgoing, Serialize)]
#[outgoing(name = "orders.done", headers = DoneMeta)]
struct Done {
    key: String,
}

#[derive(OutSlot)]
#[publishes(Done)]
struct Events;

// `Done` declares a headers contract: publishing it without `.with_headers(&meta)` does not
// compile - the empty headers position does not satisfy the declared `WithHeaders<DoneMeta>`.
#[subscriber("orders")]
async fn forward(order: &Order, Out(out): Out<impl Publisher, Events, Done>) -> HandlerOutcome {
    let _ = out
        .message(&Done {
            key: order.id.to_string(),
        })
        .publish()
        .await;
    HandlerOutcome::ack()
}

fn main() {}