pub type ArcStreamingClient = Arc<dyn CheckpointStreamingClient + Send + Sync>;Expand description
Type alias for a shared CheckpointStreamingClient trait object,
the form IngestionService stores and the broadcaster consumes.
Arc’d (rather than Box’d) because CheckpointStreamingClient’s
methods take &self, so the client can be cheaply cloned and shared
across owners – each cohort’s IngestionService gets its own clone.
The Send + Sync bounds let it move across task boundaries and be
shared behind a reference when an enclosing IngestionService is
held across threads.
Aliased Type§
pub struct ArcStreamingClient { /* private fields */ }