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

EventGatherer

internal interface EventGatherer

Responsible for fetching events from a remote source, orchestrating between events missed since the last time we gathered events and new events being received in real time.

Inheritors

Properties

Link copied to clipboard
abstract val currentSource: <Error class: unknown class><EventSource>

Functions

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

Fetches events from remote sources, handling websocket opening and duplication of events from multiple sources.