mirror of
https://github.com/element-hq/element-android
synced 2024-10-23 11:16:33 +03:00
Detekt: fix RethrowCaughtException
This commit is contained in:
parent
21904054a5
commit
aeb6495253
2 changed files with 10 additions and 15 deletions
|
@ -69,6 +69,7 @@ internal class DefaultSendEventTask @Inject constructor(
|
||||||
}
|
}
|
||||||
} catch (e: Throwable) {
|
} catch (e: Throwable) {
|
||||||
// localEchoRepository.updateSendState(params.event.eventId!!, SendState.UNDELIVERED)
|
// localEchoRepository.updateSendState(params.event.eventId!!, SendState.UNDELIVERED)
|
||||||
|
Timber.w(e, "Unable to send the Event")
|
||||||
throw e
|
throw e
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -15,7 +15,6 @@
|
||||||
*/
|
*/
|
||||||
package org.matrix.android.sdk.internal.crypto.tasks
|
package org.matrix.android.sdk.internal.crypto.tasks
|
||||||
|
|
||||||
import org.matrix.android.sdk.api.failure.Failure
|
|
||||||
import org.matrix.android.sdk.internal.crypto.api.CryptoApi
|
import org.matrix.android.sdk.internal.crypto.api.CryptoApi
|
||||||
import org.matrix.android.sdk.internal.network.GlobalErrorReceiver
|
import org.matrix.android.sdk.internal.network.GlobalErrorReceiver
|
||||||
import org.matrix.android.sdk.internal.network.executeRequest
|
import org.matrix.android.sdk.internal.network.executeRequest
|
||||||
|
@ -34,20 +33,15 @@ internal class DefaultUploadSignaturesTask @Inject constructor(
|
||||||
) : UploadSignaturesTask {
|
) : UploadSignaturesTask {
|
||||||
|
|
||||||
override suspend fun execute(params: UploadSignaturesTask.Params) {
|
override suspend fun execute(params: UploadSignaturesTask.Params) {
|
||||||
try {
|
val response = executeRequest(
|
||||||
val response = executeRequest(
|
globalErrorReceiver,
|
||||||
globalErrorReceiver,
|
canRetry = true,
|
||||||
canRetry = true,
|
maxRetriesCount = 10
|
||||||
maxRetriesCount = 10
|
) {
|
||||||
) {
|
cryptoApi.uploadSignatures(params.signatures)
|
||||||
cryptoApi.uploadSignatures(params.signatures)
|
}
|
||||||
}
|
if (response.failures?.isNotEmpty() == true) {
|
||||||
if (response.failures?.isNotEmpty() == true) {
|
throw Throwable(response.failures.toString())
|
||||||
throw Throwable(response.failures.toString())
|
|
||||||
}
|
|
||||||
return
|
|
||||||
} catch (f: Failure) {
|
|
||||||
throw f
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue