Home
last modified time | relevance | path

Searched refs:MutableSharedFlow (Results 1 – 14 of 14) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/
DSharedFlowTest.kt18 val sh = MutableSharedFlow<Int?>() in <lambda>()
91 val sh = MutableSharedFlow<Int>() in <lambda>()
137 val sh = MutableSharedFlow<Int?>(1) in <lambda>()
206 val sh = MutableSharedFlow<Int>(1) in <lambda>()
259 val sh = MutableSharedFlow<Int>( in <lambda>()
328 val sh = MutableSharedFlow<Int>(replay = 0, extraBufferCapacity = n) in <lambda>()
360 val sh = MutableSharedFlow<Int>(n) in <lambda>()
383 val sh = MutableSharedFlow<Int>() in <lambda>()
445 val sh = MutableSharedFlow<Int>(replay, extraBufferCapacity) in <lambda>()
457 …private suspend fun testBufferedFlow(sh: MutableSharedFlow<Int>, replay: Int) = withContext(Job())… in <lambda>()
[all …]
DSharedFlowScenarioTest.kt18 testSharedFlow(MutableSharedFlow<Int>(1, 2)) { in <lambda>()
98 testSharedFlow(MutableSharedFlow<Int>(1)) { in <lambda>()
145 testSharedFlow<Int>(MutableSharedFlow(2, 2, BufferOverflow.DROP_OLDEST)) { in <lambda>()
178 testSharedFlow<Int>(MutableSharedFlow(1)) { in <lambda>()
203 testSharedFlow<Int>(MutableSharedFlow(1)) { in <lambda>()
223 testSharedFlow<Int>(MutableSharedFlow( replay = 1, extraBufferCapacity = 1)) { in <lambda>()
244 sharedFlow: MutableSharedFlow<T>, in <lambda>()
272 val sharedFlow: MutableSharedFlow<T>, in <lambda>()
DShareInFusionTest.kt15 assertTrue(sh !is MutableSharedFlow<*>) // cannot be cast to mutable shared flow!!! in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DSharedFlowStressTest.kt17 private lateinit var sf: MutableSharedFlow<Long> in <lambda>()
41 sf = MutableSharedFlow(replay, extraBufferCapacity) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
DShare.kt137 val shared = MutableSharedFlow<T>( in <lambda>()
193 shared: MutableSharedFlow<T>, in launchSharing()
357 public fun <T> MutableSharedFlow<T>.asSharedFlow(): SharedFlow<T> = in asSharedFlow()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DSharedFlow.kt177 public interface MutableSharedFlow<T> : SharedFlow<T>, FlowCollector<T> { interface
277 public fun <T> MutableSharedFlow( in emit() method
281 ): MutableSharedFlow<T> { in emit()
321 ) : AbstractSharedFlow<SharedFlowSlot>(), MutableSharedFlow<T>, CancellableFlow<T>, FusibleFlow<T> {
DStateFlow.kt158 public interface MutableStateFlow<T> : StateFlow<T>, MutableSharedFlow<T> {
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
DLintTest.kt14 val sharedFlow = MutableSharedFlow<Int>() in <lambda>()
DTimeoutTest.kt194 MutableSharedFlow<Int>().asSharedFlow().timeout(100.milliseconds).collect() in <lambda>()
203 val mutableSharedFlow = MutableSharedFlow<Int>() in <lambda>()
DOnCompletionTest.kt297 .onCompletion { emitAll(MutableSharedFlow()) } in <lambda>()
/external/accompanist/web/src/main/java/com/google/accompanist/web/
DWebView.kt54 import kotlinx.coroutines.flow.MutableSharedFlow in <lambda>()
563 private val navigationEvents: MutableSharedFlow<NavigationEvent> = MutableSharedFlow(replay = 1)
/external/kotlinx.coroutines/kotlinx-coroutines-core/
DREADME.md68 | [MutableSharedFlow][kotlinx.coroutines.flow.MutableSharedFlow] | hot | Allows emittin…
161 [kotlinx.coroutines.flow.MutableSharedFlow]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-…
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.klib.api167 …w/MutableSharedFlow : kotlinx.coroutines.flow/FlowCollector<#A>, kotlinx.coroutines.flow/SharedFlo…
168 …abstract val subscriptionCount // kotlinx.coroutines.flow/MutableSharedFlow.subscriptionCount|{}su…
169 …nx.coroutines.flow/StateFlow<kotlin/Int> // kotlinx.coroutines.flow/MutableSharedFlow.subscription…
171 …abstract fun resetReplayCache() // kotlinx.coroutines.flow/MutableSharedFlow.resetReplayCache|rese…
172 …abstract fun tryEmit(#A): kotlin/Boolean // kotlinx.coroutines.flow/MutableSharedFlow.tryEmit|tryE…
173 abstract suspend fun emit(#A) // kotlinx.coroutines.flow/MutableSharedFlow.emit|emit(1:0){}[0]
176 … kotlinx.coroutines.flow/MutableStateFlow : kotlinx.coroutines.flow/MutableSharedFlow<#A>, kotlinx…
900 …MutableSharedFlow<#A>).kotlinx.coroutines.flow/asSharedFlow(): kotlinx.coroutines.flow/SharedFlow<…
917 …MutableSharedFlow(kotlin/Int = ..., kotlin/Int = ..., kotlinx.coroutines.channels/BufferOverflow =…
Dkotlinx-coroutines-core.api995 …public static final fun asSharedFlow (Lkotlinx/coroutines/flow/MutableSharedFlow;)Lkotlinx/corouti…
1151 public abstract interface class kotlinx/coroutines/flow/MutableSharedFlow : kotlinx/coroutines/flow…
1158 … kotlinx/coroutines/flow/MutableStateFlow : kotlinx/coroutines/flow/MutableSharedFlow, kotlinx/cor…
1170 …blic static final fun MutableSharedFlow (IILkotlinx/coroutines/channels/BufferOverflow;)Lkotlinx/c…
1171 …etic fun MutableSharedFlow$default (IILkotlinx/coroutines/channels/BufferOverflow;ILjava/lang/Obje…