EventGathererImpl

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

Constructors

constructor(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, serverTimeHandler: ServerTimeHandler = ServerTimeHandlerImpl(), logger: <Error class: unknown class> = kaliumLogger)

open override val currentSource: <Error class: unknown class><EventSource>

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.

open suspend override fun liveEvents(): <Error class: unknown class><Unit>