ruststream-sea-file 0.6.0

File and stdio stream implementation of the RustStream broker contract, built on sea-streamer.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

//! In-process test support, behind the `testing` feature.
//!
//! [`FileTestBroker`] is a handler-stub transport that reproduces the crate's core routing in
//! memory - no server, no network - and implements
//! [`TestableBroker`](ruststream::testing::TestableBroker) on its connected form, so
//! application handlers can be unit-tested with the
//! [`TestApp`](ruststream::testing::TestApp) harness. It routes by exact address match and does
//! not simulate broker-specific semantics (dead-letter policies, credit, redelivery timing);
//! those are verified end to end against a real broker.

mod broker;
mod router;
mod subscriber;

pub use broker::{ConnectedFileTestBroker, FileTestBroker, FileTestPublish, FileTestPublisher};
pub use subscriber::{FileTestMessage, FileTestSubscriber};