File tree 1 file changed +6
-2
lines changed
kotlinx-coroutines-core/common/src/flow
1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change 1
1
package kotlinx.coroutines.flow
2
2
3
3
import kotlinx.coroutines.*
4
- import kotlinx.coroutines.internal.IgnoreJreRequirement
4
+ import kotlinx.coroutines.flow.SharingStarted.Companion.Eagerly
5
+ import kotlinx.coroutines.flow.SharingStarted.Companion.Lazily
6
+ import kotlinx.coroutines.flow.SharingStarted.Companion.WhileSubscribed
7
+ import kotlinx.coroutines.flow.internal.*
8
+ import kotlinx.coroutines.internal.*
5
9
import kotlin.time.*
6
10
7
11
/* *
@@ -146,7 +150,7 @@ private class StartedEagerly : SharingStarted {
146
150
}
147
151
148
152
private class StartedLazily : SharingStarted {
149
- override fun command (subscriptionCount : StateFlow <Int >): Flow <SharingCommand > = flow {
153
+ override fun command (subscriptionCount : StateFlow <Int >): Flow <SharingCommand > = unsafeFlow {
150
154
var started = false
151
155
subscriptionCount.collect { count ->
152
156
if (count > 0 && ! started) {
You can’t perform that action at this time.
0 commit comments