ruststream 0.4.0

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
39
40
41

//! Application object, middleware and dispatch.

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

pub use crate::Extensions;
pub use app::{AppInfo, BrokerScope, RustStream, RustStreamError};
pub use batch::{BatchDef, BatchResult, IntoBatchResult, SliceHandler, TypedBatch};
pub use batch_publishing::{BatchPublishingDef, BatchPublishingHandler};
pub use context::{After, Context, State};
pub use dispatch::{RETRY_COUNT_HEADER, Workers};
pub use dynstack::{DynMiddleware, DynStack, DynStackHandler, Next};
pub use failure::{FailurePolicies, FailurePolicy};
pub use handler::{Handler, HandlerResult, IntoSettle, Settle};
pub use metadata::HandlerMetadata;
pub use middleware::{BlanketLayer, HandlerExt, Identity, Layer, Stack, layers};
pub use publish::{
    Outgoing, PublishIdentity, PublishLayer, PublishMiddleware, PublishNext, PublishStack,
    ReplyPublisher, ScopedPublisher, Transactional, TypedPublisher,
};
pub use publisher_registry::ErasedPublisher;
pub use publishing::{PublishingDef, PublishingHandler};
pub use router::{Router, RouterDef, RouterSink};
pub use subscriber_def::SubscriberDef;
pub use typed::{Typed, typed};