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, 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, 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(eventEnvelope: EventEnvelope): Either<CoreFailure, Unit>

Process the eventEnvelope, persisting the last processed event ID if the event is not transient (see EventDeliveryInfo.isTransient). If the processing fails, the last processed event ID will not be updated.