[streaming] PersistanceCollector, AckerCollector, StreamSourceCollector, XorEvent wip