Type Alias SinkCommittedEpochSubscriber

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

Aliased Type

struct SinkCommittedEpochSubscriber { /* private fields */ }