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

EventGathererImpl

internal class EventGathererImpl(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, logger: <Error class: unknown class> = kaliumLogger) : EventGatherer

Constructors

Link copied to clipboard
constructor(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, logger: <Error class: unknown class> = kaliumLogger)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open suspend override 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.