pipedream_rs/lib.rs
1mod envelope;
2mod error;
3mod events;
4mod stream;
5mod subscription;
6mod tracker;
7
8pub use events::Dropped;
9
10pub use envelope::Envelope;
11pub use error::{PanicError, RelayError};
12
13// Public channel API - the recommended way to create relays
14pub use stream::{ReadyGuard, Relay, RelayReceiver, RelaySender, SendError, WeakSender};
15
16// Keep Subscription public for typed message receiving
17pub use subscription::Subscription;
18
19// Internal types - not part of public API but needed for advanced use cases
20#[doc(hidden)]
21pub use stream::IntoResult;
22
23pub use tracker::CompletionTracker;
24
25#[cfg(test)]
26mod tests;