[SHARED] Build fix
This commit is contained in:
+1
-1
@@ -1,4 +1,4 @@
|
||||
org.gradle.configureondemand=true
|
||||
org.gradle.configureondemand=false
|
||||
org.gradle.caching=true
|
||||
org.gradle.parallel=true
|
||||
org.gradle.jvmargs=-Xmx8192M -Dfile.encoding=UTF-8
|
||||
|
||||
@@ -7,15 +7,6 @@
|
||||
resolved "https://registry.yarnpkg.com/@js-joda/core/-/core-3.2.0.tgz#3e61e21b7b2b8a6be746df1335cf91d70db2a273"
|
||||
integrity sha512-PMqgJ0sw5B7FKb2d5bWYIoxjri+QlW/Pys7+Rw82jSH0QN3rB05jZ/VrrsUdh1w4+i2kw9JOejXGq/KhDOX7Kg==
|
||||
|
||||
cross-spawn@7.0.5:
|
||||
version "7.0.5"
|
||||
resolved "https://registry.yarnpkg.com/cross-spawn/-/cross-spawn-7.0.5.tgz#910aac880ff5243da96b728bc6521a5f6c2f2f82"
|
||||
integrity sha512-ZVJrKKYunU38/76t0RMOulHOnUcbU9GbpWKAOZ0mhjr7CX6FVrH+4FrAapSOekrgFQ3f/8gwMEuIft0aKq6Hug==
|
||||
dependencies:
|
||||
path-key "^3.1.0"
|
||||
shebang-command "^2.0.0"
|
||||
which "^2.0.1"
|
||||
|
||||
cross-spawn@7.0.6:
|
||||
version "7.0.6"
|
||||
resolved "https://registry.yarnpkg.com/cross-spawn/-/cross-spawn-7.0.6.tgz#8a58fe78f00dcd70c370451759dfbfaf03e8ee9f"
|
||||
|
||||
@@ -16,13 +16,11 @@
|
||||
package com.kgurgul.cpuinfo.domain
|
||||
|
||||
import kotlinx.coroutines.CoroutineDispatcher
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import kotlinx.coroutines.flow.Flow
|
||||
import kotlinx.coroutines.flow.MutableSharedFlow
|
||||
import kotlinx.coroutines.flow.flatMapLatest
|
||||
import kotlinx.coroutines.flow.flowOn
|
||||
import kotlinx.coroutines.flow.onSubscription
|
||||
import kotlinx.coroutines.launch
|
||||
import kotlinx.coroutines.withContext
|
||||
|
||||
interface Interactor {
|
||||
@@ -64,8 +62,3 @@ abstract class ResultInteractor<in P, R> : Interactor {
|
||||
fun <T> ImmutableInteractor<Unit, T>.observe() = observe(Unit)
|
||||
|
||||
operator fun <T> MutableInteractor<Unit, T>.invoke() = invoke(Unit)
|
||||
|
||||
fun <I : MutableInteractor<P, T>, P, T> CoroutineScope.launchObserve(
|
||||
interactor: I,
|
||||
f: suspend (Flow<T>) -> Unit,
|
||||
) = launch(interactor.dispatcher) { f(interactor.observe()) }
|
||||
|
||||
Reference in New Issue
Block a user