ruststream 0.2.3

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

//! Application object, middleware and dispatch.

mod app;
pub mod cli;
mod context;
mod dispatch;
mod dynstack;
mod handler;
mod lifecycle;
mod metadata;
mod middleware;
mod publish;
mod publisher_registry;
mod publishing;
mod router;
mod subscriber_def;
mod typed;

pub use app::{AppInfo, BrokerScope, RustStream, RustStreamError};
pub use context::{Context, State};
pub use dynstack::{DynMiddleware, DynStack, DynStackHandler, Next};
pub use handler::{Handler, HandlerResult, IntoHandlerResult};
pub use metadata::HandlerMetadata;
pub use middleware::{HandlerExt, Identity, Layer, Stack, layers};
pub use publish::{
    Outgoing, PublishIdentity, PublishLayer, PublishMiddleware, PublishNext, PublishStack,
    ScopedPublisher, TypedPublisher,
};
pub use publisher_registry::ErasedPublisher;
pub use publishing::{PublishingDef, PublishingHandler};
pub use router::{Router, RouterCodec};
pub use subscriber_def::SubscriberDef;
pub use typed::{DecodeFailure, Typed, typed};