ruststream 0.2.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

//! A multi-file RustStream service: macro handlers in [`orders`], wiring in [`routes`], and a
//! `#[ruststream::app]` entry point here that mounts the router.
//!
//! Run it with `cargo run --example routed_service --features macros,memory -- run`, or generate
//! its AsyncAPI document with `... --features macros,memory,asyncapi -- asyncapi gen`.

mod orders;
mod routes;
mod stream;

use ruststream::memory::MemoryBroker;
use ruststream::runtime::{AppInfo, RustStream};

/// Builds the service. `#[ruststream::app]` generates `main`, so there is no runtime boilerplate.
#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders-service", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
        let router = routes::orders(b.broker());
        b.include_router(router);
    })
}