OneOnOneResolverImpl
internal class OneOnOneResolverImpl(userRepository: UserRepository, oneOnOneProtocolSelector: OneOnOneProtocolSelector, oneOnOneMigrator: OneOnOneMigrator, incrementalSyncRepository: IncrementalSyncRepository, pendingActionsRepository: PendingActionsRepository, conversationRepository: ConversationRepository, mlsConversationRepository: MLSConversationRepository, maxConcurrentResolutions: Int = DEFAULT_MAX_CONCURRENT_RESOLUTIONS, maxThrottleRetries: Int = DEFAULT_MAX_THROTTLE_RETRIES, throttleRetryDelayMs: Long = DEFAULT_THROTTLE_RETRY_DELAY_MS, kaliumDispatcher: KaliumDispatcher = KaliumDispatcherImpl) : OneOnOneResolver
Constructors
Link copied to clipboard
constructor(userRepository: UserRepository, oneOnOneProtocolSelector: OneOnOneProtocolSelector, oneOnOneMigrator: OneOnOneMigrator, incrementalSyncRepository: IncrementalSyncRepository, pendingActionsRepository: PendingActionsRepository, conversationRepository: ConversationRepository, mlsConversationRepository: MLSConversationRepository, maxConcurrentResolutions: Int = DEFAULT_MAX_CONCURRENT_RESOLUTIONS, maxThrottleRetries: Int = DEFAULT_MAX_THROTTLE_RETRIES, throttleRetryDelayMs: Long = DEFAULT_THROTTLE_RETRY_DELAY_MS, kaliumDispatcher: KaliumDispatcher = KaliumDispatcherImpl)
Functions
Link copied to clipboard
open suspend override fun resolveAllOneOnOneConversations(transactionContext: CryptoTransactionContext, synchronizeUsers: Boolean = false, allowJoinByExternalCommit: Boolean = true): Either<CoreFailure, Unit>
Link copied to clipboard
open suspend override fun resolveOneOnOneConversationWithUser(transactionContext: CryptoTransactionContext, user: OtherUser, invalidateCurrentKnownProtocols: Boolean, fallbackToMLS: Boolean = false): Either<CoreFailure, ConversationId>
Resolves a one-on-one conversation with a user.
Link copied to clipboard
open suspend override fun resolveOneOnOneConversationWithUserId(transactionContext: CryptoTransactionContext, userId: UserId, invalidateCurrentKnownProtocols: Boolean): Either<CoreFailure, ConversationId>
Resolves a one-on-one conversation with a user based on their userId.
Link copied to clipboard
open suspend override fun scheduleResolveOneOnOneConversationWithUserId(transactionContext: CryptoTransactionContext, userId: UserId, delay: Duration = Duration.ZERO): Job