pipedream-rs 0.2.0

A typed, heterogeneous event relay with observable delivery, completion tracking, and lossless message routing
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

mod envelope;
mod error;
mod events;
mod stream;
mod subscription;
mod tracker;

pub use events::Dropped;

pub use envelope::Envelope;
pub use error::{PanicError, RelayError};

// Public channel API - the recommended way to create relays
pub use stream::{ReadyGuard, Relay, RelayReceiver, RelaySender, SendError, WeakSender};

// Keep Subscription public for typed message receiving
pub use subscription::Subscription;

// Internal types - not part of public API but needed for advanced use cases
#[doc(hidden)]
pub use stream::IntoResult;

pub use tracker::CompletionTracker;

#[cfg(test)]
mod tests;