Home
last modified time | relevance | path

Searched refs:onBufferOverflow (Results 1 – 22 of 22) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
DBufferConflationTest.kt20 onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()
25 val expectedList = when (onBufferOverflow) { in <lambda>()
59 buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
65 buffer(0, onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
71 buffer(1, onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
77 buffer(10, onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
101 buffer(onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
107 buffer(0, onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
113 buffer(1, onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
119 buffer(42).buffer(onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/
DShareInConflationTest.kt20 onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()
37 … val first = if (onBufferOverflow == BufferOverflow.DROP_LATEST) 0 else n - bufferCapacity in <lambda>()
70 … buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 1) in <lambda>()
76 … buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 0) in <lambda>()
82 … buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 10) in <lambda>()
88 … buffer(20, onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 0) in <lambda>()
94 … buffer(7, onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 11) in <lambda>()
106 …buffer(23).buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerl… in <lambda>()
112 … buffer(onBufferOverflow = BufferOverflow.DROP_LATEST).shareIn(it, SharingStarted.Eagerly, 0) in <lambda>()
118 … buffer(onBufferOverflow = BufferOverflow.DROP_LATEST).shareIn(it, SharingStarted.Eagerly, 1) in <lambda>()
[all …]
DStateInTest.kt25 assertSame(state, state.buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST)) in <lambda>()
26 assertSame(state, state.buffer(0, onBufferOverflow = BufferOverflow.DROP_OLDEST)) in <lambda>()
27 assertSame(state, state.buffer(1, onBufferOverflow = BufferOverflow.DROP_OLDEST)) in <lambda>()
DSharedFlowTest.kt515 val sh = MutableSharedFlow<Int?>(1, onBufferOverflow = bufferOverflow) in <lambda>()
688 onBufferOverflow = BufferOverflow.DROP_OLDEST in <lambda>()
763 …assertFailsWith<IllegalArgumentException> { MutableSharedFlow<Int>(0, onBufferOverflow = BufferOve… in <lambda>()
764 …assertFailsWith<IllegalArgumentException> { MutableSharedFlow<Int>(0, onBufferOverflow = BufferOve… in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DMerge.kt18 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
19 ) : ChannelFlowOperator<T, R>(flow, context, capacity, onBufferOverflow) { in <lambda>()
20 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in <lambda>()
21 ChannelFlowTransformLatest(transform, flow, context, capacity, onBufferOverflow) in <lambda>()
46 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND
47 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) {
48 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in create()
49 ChannelFlowMerge(flow, concurrency, context, capacity, onBufferOverflow) in create()
84 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in additionalToStringProps()
85 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in additionalToStringProps()
[all …]
DChannelFlow.kt33 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
52 @JvmField public val onBufferOverflow: BufferOverflow constant in kotlinx.coroutines.flow.internal.ChannelFlow
73 …public override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflo… in dropChannelOperators()
79 if (onBufferOverflow != BufferOverflow.SUSPEND) { in dropChannelOperators()
82 newOverflow = onBufferOverflow in dropChannelOperators()
99 newOverflow = this.onBufferOverflow in dropChannelOperators()
101 …newContext == this.context && newCapacity == this.capacity && newOverflow == this.onBufferOverflow) in dropChannelOperators()
106 …protected abstract fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOv… in create()
119 …scope.produce(context, produceCapacity, onBufferOverflow, start = CoroutineStart.ATOMIC, block = c… in create()
134 … if (onBufferOverflow != BufferOverflow.SUSPEND) props.add("onBufferOverflow=$onBufferOverflow") in additionalToStringProps()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
DContext.kt125 public fun <T> Flow<T>.buffer(capacity: Int = BUFFERED, onBufferOverflow: BufferOverflow = BufferOv… in buffer()
129 require(capacity != CONFLATED || onBufferOverflow == BufferOverflow.SUSPEND) { in buffer()
134 var onBufferOverflow = onBufferOverflow in buffer() variable
137 onBufferOverflow = BufferOverflow.DROP_OLDEST in buffer()
141 is FusibleFlow -> fuse(capacity = capacity, onBufferOverflow = onBufferOverflow) in buffer()
142 … else -> ChannelFlowOperatorImpl(this, capacity = capacity, onBufferOverflow = onBufferOverflow) in buffer()
DShare.kt144 onBufferOverflow = config.onBufferOverflow in <lambda>()
154 @JvmField val onBufferOverflow: BufferOverflow, constant in kotlinx.coroutines.flow.SharingConfig
172 … onBufferOverflow == BufferOverflow.SUSPEND -> // buffer was configured with suspension in configureSharing()
179 onBufferOverflow = onBufferOverflow, in configureSharing()
188 onBufferOverflow = BufferOverflow.SUSPEND, in configureSharing()
375 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in asSharedFlow()
376 fuseSharedFlow(context, capacity, onBufferOverflow) in asSharedFlow()
384 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in fuse()
385 fuseStateFlow(context, capacity, onBufferOverflow) in fuse()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DBuilders.kt314 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in channelFlow()
315 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in channelFlow()
316 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in channelFlow()
317 ChannelFlowBuilder(block, context, capacity, onBufferOverflow) in channelFlow()
330 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND
331 ) : ChannelFlowBuilder<T>(block, context, capacity, onBufferOverflow) {
351 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C…
352 CallbackFlowBuilder(block, context, capacity, onBufferOverflow)
DSharedFlow.kt266 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in emit()
270 require(replay > 0 || extraBufferCapacity > 0 || onBufferOverflow == BufferOverflow.SUSPEND) { in emit()
271 … extraBufferCapacity must be positive with non-default onBufferOverflow strategy $onBufferOverflow" in emit()
275 return SharedFlowImpl(replay, bufferCapacity, onBufferOverflow) in emit()
305 private val onBufferOverflow: BufferOverflow constant in kotlinx.coroutines.flow.SharedFlowImpl
415 when (onBufferOverflow) { in tryEmitLocked()
699 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in fuse()
700 fuseSharedFlow(context, capacity, onBufferOverflow) in fuse()
721 onBufferOverflow: BufferOverflow in Array()
725 …y == Channel.RENDEZVOUS || capacity == Channel.OPTIONAL_CHANNEL) && onBufferOverflow == BufferOver… in Array()
[all …]
DChannels.kt99 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in receiveAsFlow()
100 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in receiveAsFlow()
109 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in receiveAsFlow()
110 ChannelAsFlow(channel, consume, context, capacity, onBufferOverflow) in receiveAsFlow()
DStateFlow.kt412 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in createSlot()
413 fuseStateFlow(context, capacity, onBufferOverflow) in createSlot()
419 onBufferOverflow: BufferOverflow in createSlot()
423 …if ((capacity in 0..1 || capacity == Channel.BUFFERED) && onBufferOverflow == BufferOverflow.DROP_… in createSlot()
426 return fuseSharedFlow(context, capacity, onBufferOverflow) in createSlot()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DReactiveFlow.kt52 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
53 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in <lambda>()
54 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in <lambda>()
55 PublisherAsFlow(publisher, context, capacity, onBufferOverflow) in <lambda>()
65 if (onBufferOverflow != BufferOverflow.SUSPEND) { in <lambda>()
92 val subscriber = ReactiveSubscriber<T>(capacity, onBufferOverflow, requestSize) in <lambda>()
119 onBufferOverflow: BufferOverflow,
126 …ate val channel = Channel<T>(if (capacity == Channel.RENDEZVOUS) 1 else capacity, onBufferOverflow)
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DChannel.kt775 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND, in Channel()
780 if (onBufferOverflow == BufferOverflow.SUSPEND) in Channel()
783 …ConflatedBufferedChannel(1, onBufferOverflow, onUndeliveredElement) // support buffer overflow wit… in Channel()
786 require(onBufferOverflow == BufferOverflow.SUSPEND) { in Channel()
793 …if (onBufferOverflow == BufferOverflow.SUSPEND) BufferedChannel(CHANNEL_DEFAULT_CAPACITY, onUndeli… in Channel()
794 else ConflatedBufferedChannel(1, onBufferOverflow, onUndeliveredElement) in Channel()
797 … if (onBufferOverflow === BufferOverflow.SUSPEND) BufferedChannel(capacity, onUndeliveredElement) in Channel()
798 else ConflatedBufferedChannel(capacity, onBufferOverflow, onUndeliveredElement) in Channel()
DConflatedBufferedChannel.kt24 private val onBufferOverflow: BufferOverflow, in <lambda>() constant in kotlinx.coroutines.channels.ConflatedBufferedChannel
28 require(onBufferOverflow !== SUSPEND) { in <lambda>()
37 get() = onBufferOverflow == DROP_OLDEST in <lambda>()
60 if (onBufferOverflow === DROP_LATEST) trySendDropLatest(element, isSendOp) in <lambda>()
DProduce.kt123 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND, in produce()
128 val channel = Channel<E>(capacity, onBufferOverflow) in produce()
DBroadcastChannel.kt369 …ass SubscriberConflated : ConflatedBufferedChannel<E>(capacity = 1, onBufferOverflow = DROP_OLDEST…
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DPublisherAsFlowTest.kt228 onBufferOverflow: BufferOverflow, in <lambda>()
253 .buffer(capacity, onBufferOverflow) in <lambda>()
256 val expected = when (onBufferOverflow) { in <lambda>()
/external/lottie/lottie-compose/src/main/java/com/airbnb/lottie/compose/
DLottieRetrySignal.kt33 private val channel = Channel<Unit>(capacity = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DChannelUndeliveredElementTest.kt152 onBufferOverflow = strategy, in <lambda>()
/external/kotlinx.coroutines/ui/
Dcoroutines-guide-ui.md339 `onBufferOverflow = DROP_OLDEST` or `onBufferOverflow = DROP_LATEST`) avoids delays
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.api1216 public final field onBufferOverflow Lkotlinx/coroutines/channels/BufferOverflow;