ruststream 0.7.5

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

//! A minimal service wired with `#[ruststream::app]`: no hand-written `main`, no runtime setup.
//!
//! The attribute expands the builder below into a binary that understands `run` (the default) and
//! `asyncapi gen`. Try it with `cargo run --example macro_app --features macros,memory -- run`.

use std::future::{Future, ready};

use ruststream::memory::prelude::*;

/// The raw input type: the derive gives the newtype the delivery's bytes as they arrive.
#[derive(Deserialized)]
struct RawOrder<'a>(&'a [u8]);

/// A raw-payload body: `RawOrder` borrows the delivery's bytes, so this service needs no codec
/// feature at all.
struct Ingest;

impl<'p> Handle<RawOrder<'p>> for Ingest {
    fn handle(
        &self,
        order: &RawOrder<'p>,
        _outs: &(),
        _ctx: &mut Context<'_>,
    ) -> impl Future<Output = Result<(), HandlerOutcome>> {
        let _ = order.0.len();
        ready(Ok(()))
    }
}

#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
        b.include(subscriber("orders", Ingest).build());
    })
}