Skip to main content

StreamingSinkTx

Type Alias StreamingSinkTx 

Source
pub type StreamingSinkTx = Arc<Sender<StreamDelta>>;
Expand description

Connection-scoped streaming sink sender.

Wrapped in Arc so it can be cloned cheaply across the orchestrator → lifecycle → runtime boundary. The receiver lives in a collector task owned by the gateway dispatch layer; see the design doc §8.1 for the conn_id scoping rationale.

Aliased Type§

pub struct StreamingSinkTx { /* private fields */ }