processEventsFlow

open suspend override fun processEventsFlow(): Flow<EventSource>

Upon collection, will start collecting and processing events, emitting the source of current events.