logic/com.wire.kalium.logic.sync.incremental/EventGatherer

EventGatherer

internal interface EventGatherer

Orchestrates the reception of events from remote sources, coordinating between historical (pending) and real-time (live) event delivery modes.

In environments with async notifications enabled, it emits only real-time events from WebSocket. In legacy environments, it first fetches pending events and then transitions to live updates.

Inheritors

Functions

Link copied to clipboard
abstract suspend fun gatherEvents(): <Error class: unknown class><EventStreamData>

Establishes a WebSocket connection and starts receiving events in real time. Waits until an initial connection is established before starting to emit all unprocessed events stored locally.