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

EventProcessorImpl

internal class EventProcessorImpl(eventRepository: EventRepository, conversationEventReceiver: ConversationEventReceiver, userEventReceiver: UserEventReceiver, teamEventReceiver: TeamEventReceiver, featureConfigEventReceiver: FeatureConfigEventReceiver, userPropertiesEventReceiver: UserPropertiesEventReceiver, federationEventReceiver: FederationEventReceiver, missedNotificationsEventReceiver: MissedNotificationsEventReceiver, processingScope: <Error class: unknown class>, logger: <Error class: unknown class> = kaliumLogger) : EventProcessor

Constructors

Link copied to clipboard
constructor(eventRepository: EventRepository, conversationEventReceiver: ConversationEventReceiver, userEventReceiver: UserEventReceiver, teamEventReceiver: TeamEventReceiver, featureConfigEventReceiver: FeatureConfigEventReceiver, userPropertiesEventReceiver: UserPropertiesEventReceiver, federationEventReceiver: FederationEventReceiver, missedNotificationsEventReceiver: MissedNotificationsEventReceiver, processingScope: <Error class: unknown class>, logger: <Error class: unknown class> = kaliumLogger)

Properties

Link copied to clipboard
open override var disableEventProcessing: Boolean

When enabled events will be consumed but no event processing will occur.

Functions

Link copied to clipboard
open suspend override fun processEvent(transactionContext: <Error class: unknown class>, eventEnvelope: EventEnvelope): <Error class: unknown class><<Error class: unknown class>, Unit>

Processes a single eventEnvelope using the provided transactionContext.