Type Alias SinkCommittedEpochSubscriber

Source
pub type SinkCommittedEpochSubscriber = Arc<dyn Fn(SinkId) -> BoxFuture<'static, Result<(u64, UnboundedReceiver<u64>)>> + Send + Sync + 'static>;

Aliased Typeยง

struct SinkCommittedEpochSubscriber { /* private fields */ }