Crate pipedream_rs

Structs§

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.
ReadyGuard: Guard that ensures ready is signaled even if task panics or is cancelled. Created via ReadyGuard::new(), signals on drop if not already signaled. IMPORTANT: After calling signal(), the Arc is released to allow proper cleanup when the parent stream is dropped.
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.