Expand description
Native callback streams over the backend subscription router.
The receiver owns the shared wires and their suspension intent
(shared_wires); this module keeps the app’s suspend and resume calls.
Retryable wire failures keep leases alive and reconnect with backoff.
Each callback stream reports close on terminal failure or explicit close.
Re-exports§
pub use super::incoming::stream_api::shared_wires::ApiClientIdentity;
Functions§
- resume_
bidi_ streams - Resume shared wires. Reconnect and target processing continue in their tasks.
- stream_
conversation_ messages_ with_ callback_ dispatch - suspend_
bidi_ streams - Suspend every shared wire and remember the intent for new wires.