From 7936c2c6f841c9456d3c3526999881c5ea19eb51 Mon Sep 17 00:00:00 2001 From: ganfra Date: Tue, 9 Mar 2021 20:23:06 +0100 Subject: [PATCH] Send: clean after Benoits review --- .../session/room/send/queue/EventSenderProcessorCoroutine.kt | 2 +- .../session/room/send/queue/EventSenderProcessorThread.kt | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorCoroutine.kt b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorCoroutine.kt index e93ebe9048..2972332989 100644 --- a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorCoroutine.kt +++ b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorCoroutine.kt @@ -118,7 +118,7 @@ internal class EventSenderProcessorCoroutine @Inject constructor( executeTask(task) }.toCancelable() .also { - cancelableBag[task.taskIdentifier] + cancelableBag[task.taskIdentifier] = it } } diff --git a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorThread.kt b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorThread.kt index 2d2111f838..b79a86dd7e 100644 --- a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorThread.kt +++ b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/send/queue/EventSenderProcessorThread.kt @@ -46,6 +46,7 @@ import kotlin.concurrent.schedule * * If the app is killed before all event were sent, on next wakeup the scheduled events will be re posted */ +@Deprecated("You should know use EventSenderProcessorCoroutine instead") @SessionScope internal class EventSenderProcessorThread @Inject constructor( private val cryptoService: CryptoService,