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

EventGathererImpl

internal class EventGathererImpl(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, serverTimeHandler: ServerTimeHandler = ServerTimeHandlerImpl(), processingScope: <Error class: unknown class>, liveSourceChangeHandler: LiveSourceChangeHandler = LiveSourceChangeHandlerImpl(processingScope), logger: <Error class: unknown class> = kaliumLogger) : EventGatherer

Constructors

Link copied to clipboard
constructor(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, serverTimeHandler: ServerTimeHandler = ServerTimeHandlerImpl(), processingScope: <Error class: unknown class>, liveSourceChangeHandler: LiveSourceChangeHandler = LiveSourceChangeHandlerImpl(processingScope), logger: <Error class: unknown class> = kaliumLogger)

Properties

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

Functions

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

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

Link copied to clipboard
open suspend override fun liveEvents(): <Error class: unknown class><Unit>