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

EventProcessorImpl

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

Constructors

Link copied to clipboard
constructor(conversationEventReceiver: ConversationEventReceiver, userEventReceiver: UserEventReceiver, teamEventReceiver: TeamEventReceiver, featureConfigEventReceiver: FeatureConfigEventReceiver, userPropertiesEventReceiver: UserPropertiesEventReceiver, federationEventReceiver: FederationEventReceiver, 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>, String?>

Processes a single eventEnvelope using the provided transactionContext.