EventProcessorImpl

internal class EventProcessorImpl(conversationEventReceiver: ConversationEventReceiver, userEventReceiver: UserEventReceiver, teamEventReceiver: TeamEventReceiver, featureConfigEventReceiver: FeatureConfigEventReceiver, userPropertiesEventReceiver: UserPropertiesEventReceiver, federationEventReceiver: FederationEventReceiver, meetingEventReceiver: MeetingEventReceiver, processingScope: CoroutineScope, logger: KaliumLogger = kaliumLogger) : EventProcessor

Constructors

constructor(conversationEventReceiver: ConversationEventReceiver, userEventReceiver: UserEventReceiver, teamEventReceiver: TeamEventReceiver, featureConfigEventReceiver: FeatureConfigEventReceiver, userPropertiesEventReceiver: UserPropertiesEventReceiver, federationEventReceiver: FederationEventReceiver, meetingEventReceiver: MeetingEventReceiver, processingScope: CoroutineScope, logger: KaliumLogger = kaliumLogger)

open override var disableEventProcessing: Boolean

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

open suspend override fun flushPendingSideEffects(): Either<CoreFailure, Unit>

open suspend override fun processEvent(transactionContext: CryptoTransactionContext, eventEnvelope: EventEnvelope): Either<CoreFailure, String?>

Processes a single eventEnvelope using the provided transactionContext.