observeUnprocessedEvents

open override fun observeUnprocessedEvents(limit: Long = DEFAULT_UNPROCESSED_EVENTS_LIMIT): Flow<List<EventEntity>>