Skip to main content Crate pipedream_rs Copy item path Source CompletionTracker Tracks completion of a single message across all handlers. Dropped Event emitted when a message is dropped due to a slow consumer. Envelope A type-erased envelope that can carry any Send + Sync value. PanicError Wrapper for panic payloads, converting them to an Error type. Relay A readable stream handle - can be subscribed to and piped from.
A typed, heterogeneous relay with lossless delivery and completion tracking.
Relay namespace for creating channels. RelayError Error from a downstream handler in the stream. RelayReceiver A receiver handle for subscribing to channel messages. RelaySender The single owner of a relay channel. Subscription A typed subscription to a Relay. WeakSender A weak sender handle that can send messages without keeping the channel alive. SendError