pub type BoxedStreamingClient = Box<dyn CheckpointStreamingClient + Send + Sync>;Expand description
Type alias for a boxed CheckpointStreamingClient trait object,
the form IngestionService stores and the broadcaster consumes.
Boxed (rather than Arc’d) because CheckpointStreamingClient’s
methods take &mut self, so unique ownership is required. The
Send + Sync bounds let the boxed client move across task
boundaries and be shared behind a reference when an enclosing
IngestionService is held across threads.
Aliased Type§
pub struct BoxedStreamingClient(/* private fields */);