processEventsWhilePolicyAllowsFlow
Upon collection, will start collecting and processing events, emitting the source of current events.
Flow will finish only if the ConnectionPolicy is ConnectionPolicy.DISCONNECT_AFTER_PENDING_EVENTS. Otherwise, it will keep collecting and processing events indeterminately until a failure or cancellation.