[streaming-wip] PersistanceCollector, AckerCollector, StreamSourceCollector, XorEvent wip