Gathers app event batches and publishes incremental sync progress.
Collection starts receiving and processing, emitting the source of current events.