EventGathererImpl

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

Constructors

constructor(eventRepository: EventRepository, incrementalSyncRepository: IncrementalSyncRepository, 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.