We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 90850c2 commit 8173715Copy full SHA for 8173715
server/src/main/kotlin/suwayomi/tachidesk/manga/impl/update/Updater.kt
@@ -12,6 +12,7 @@ import kotlinx.coroutines.flow.asStateFlow
12
import kotlinx.coroutines.flow.catch
13
import kotlinx.coroutines.flow.consumeAsFlow
14
import kotlinx.coroutines.flow.launchIn
15
+import kotlinx.coroutines.flow.onCompletion
16
import kotlinx.coroutines.flow.onEach
17
import kotlinx.coroutines.flow.update
18
import kotlinx.coroutines.launch
@@ -159,6 +160,7 @@ class Updater : IUpdater {
159
160
logger.error(it) { "Error during updates (source: $source)" }
161
handleChannelUpdateFailure(source)
162
}
163
+ .onCompletion { updateChannels.remove(source) }
164
.launchIn(scope)
165
return channel
166
0 commit comments