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

EventGathererImpl

internal class EventGathererImpl(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, logger: KaliumLogger = kaliumLogger) : EventGatherer

Constructors

EventGathererImpl

constructor(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, logger: KaliumLogger = kaliumLogger)

Types

Companion

object Companion

Functions

gatherEvents

open suspend override fun gatherEvents(): Flow<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.