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
14
15
16
17
18
19
20
21
22

use ruststream::memory::MemorySeeker;
use ruststream::runtime::{HandlerResult, Seek};
use ruststream::subscriber;
use serde::Deserialize;

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

// One subscription, one seeker: a second Seek parameter has nothing extra to bind to.
#[subscriber("orders")]
async fn handle(
    order: &Order,
    Seek(_a): Seek<MemorySeeker>,
    Seek(_b): Seek<MemorySeeker>,
) -> HandlerResult {
    let _ = order.id;
    HandlerResult::Ack
}

fn main() {}