impl VBoxUpdateFetcher
This commit is contained in:
@@ -5,6 +5,7 @@ import com.russhwolf.settings.Settings
|
||||
import kotlinx.coroutines.channels.awaitClose
|
||||
import kotlinx.coroutines.flow.Flow
|
||||
import kotlinx.coroutines.flow.callbackFlow
|
||||
import kotlinx.coroutines.flow.flowOn
|
||||
import kotlinx.coroutines.launch
|
||||
import kotlinx.coroutines.withContext
|
||||
import ru.shadowsparky.domain.DispatcherProvider
|
||||
@@ -27,7 +28,7 @@ class SettingsKeyValueStorage(
|
||||
}
|
||||
|
||||
override fun get(key: String): Flow<String?> {
|
||||
return impl.get(key)
|
||||
return impl.get(key).flowOn(dispatcherProvider.io)
|
||||
}
|
||||
|
||||
override suspend fun remove(key: String) = withContext(dispatcherProvider.io) {
|
||||
|
||||
Reference in New Issue
Block a user