IncrementalSyncRecoveryHandlerImpl

internal class IncrementalSyncRecoveryHandlerImpl(restartSlowSyncProcessForRecoveryUseCase: RestartSlowSyncProcessForRecoveryUseCase, eventRepository: EventRepository, logger: <Error class: unknown class> = kaliumLogger) : IncrementalSyncRecoveryHandler

Implementation of the IncrementalSyncRecoveryHandler interface.

It checks if the failure allows for recovery by checking if failure is a CoreFailure.SyncEventOrClientNotFound. If recovery is possible, it clears the last processed event ID and restarts the slow sync process.

Constructors

Link copied to clipboard
constructor(restartSlowSyncProcessForRecoveryUseCase: RestartSlowSyncProcessForRecoveryUseCase, eventRepository: EventRepository, logger: <Error class: unknown class> = kaliumLogger)

Functions

Link copied to clipboard
open suspend override fun recover(failure: CoreFailure, onIncrementalSyncRetryCallback: OnIncrementalSyncRetryCallback)