SlowSyncWorkerImpl

internal class SlowSyncWorkerImpl(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, syncSelfUser: SyncSelfUserUseCase, syncUserProperties: SyncUserPropertiesUseCase, syncFeatureConfigs: SyncFeatureConfigsUseCase, updateSupportedProtocols: UpdateSelfUserSupportedProtocolsUseCase, syncConversations: SyncConversationsUseCase, syncConnections: SyncConnectionsUseCase, syncSelfTeam: SyncSelfTeamUseCase, syncContacts: SyncContactsUseCase, joinMLSConversations: JoinExistingMLSConversationsUseCase, fetchLegalHoldForSelfUserFromRemoteUseCase: FetchLegalHoldForSelfUserFromRemoteUseCase, oneOnOneResolver: OneOnOneResolver, transactionProvider: CryptoTransactionProvider, optimizer: OptimizeDatabaseUseCase, syncMeetings: SyncMeetingsUseCase, logger: KaliumLogger = kaliumLogger, onJoinProgress: (SlowSyncProgress) -> Unit = {}) : SlowSyncWorker

Constructors

Link copied to clipboard
constructor(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, syncSelfUser: SyncSelfUserUseCase, syncUserProperties: SyncUserPropertiesUseCase, syncFeatureConfigs: SyncFeatureConfigsUseCase, updateSupportedProtocols: UpdateSelfUserSupportedProtocolsUseCase, syncConversations: SyncConversationsUseCase, syncConnections: SyncConnectionsUseCase, syncSelfTeam: SyncSelfTeamUseCase, syncContacts: SyncContactsUseCase, joinMLSConversations: JoinExistingMLSConversationsUseCase, fetchLegalHoldForSelfUserFromRemoteUseCase: FetchLegalHoldForSelfUserFromRemoteUseCase, oneOnOneResolver: OneOnOneResolver, transactionProvider: CryptoTransactionProvider, optimizer: OptimizeDatabaseUseCase, syncMeetings: SyncMeetingsUseCase, logger: KaliumLogger = kaliumLogger, onJoinProgress: (SlowSyncProgress) -> Unit = {})

Functions

Link copied to clipboard
open suspend override fun slowSyncStepsFlow(migrationSteps: List<SyncMigrationStep>): Flow<SlowSyncStep>

Performs all SlowSyncStep in the correct order, emits the current ongoing step.