Home
last modified time | relevance | path

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

12345678910>>...13

/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/
H A DShareInConflationTest.kt17 onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()
34 … val first = if (onBufferOverflow == BufferOverflow.DROP_LATEST) 0 else n - bufferCapacity in <lambda>()
67 … buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 1) in <lambda>()
73 … buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 0) in <lambda>()
79 … buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 10) in <lambda>()
85 … buffer(20, onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 0) in <lambda>()
91 … buffer(7, onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerly, 11) in <lambda>()
103 …buffer(23).buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST).shareIn(it, SharingStarted.Eagerl… in <lambda>()
109 … buffer(onBufferOverflow = BufferOverflow.DROP_LATEST).shareIn(it, SharingStarted.Eagerly, 0) in <lambda>()
115 … buffer(onBufferOverflow = BufferOverflow.DROP_LATEST).shareIn(it, SharingStarted.Eagerly, 1) in <lambda>()
[all …]
H A DStateInTest.kt22 assertSame(state, state.buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST)) in <lambda>()
23 assertSame(state, state.buffer(0, onBufferOverflow = BufferOverflow.DROP_OLDEST)) in <lambda>()
24 assertSame(state, state.buffer(1, onBufferOverflow = BufferOverflow.DROP_OLDEST)) in <lambda>()
H A DSharedFlowTest.kt512 val sh = MutableSharedFlow<Int?>(1, onBufferOverflow = bufferOverflow) in <lambda>()
685 onBufferOverflow = BufferOverflow.DROP_OLDEST in <lambda>()
760 …assertFailsWith<IllegalArgumentException> { MutableSharedFlow<Int>(0, onBufferOverflow = BufferOve… in <lambda>()
761 …assertFailsWith<IllegalArgumentException> { MutableSharedFlow<Int>(0, onBufferOverflow = BufferOve… in <lambda>()
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
H A DBufferConflationTest.kt17 onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()
22 val expectedList = when (onBufferOverflow) { in <lambda>()
56 buffer(onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
62 buffer(0, onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
68 buffer(1, onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
74 buffer(10, onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
98 buffer(onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
104 buffer(0, onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
110 buffer(1, onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
116 buffer(42).buffer(onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
[all …]
H A DBufferTest.kt190 …legalArgumentException> { flow.buffer(capacity = Channel.CONFLATED, onBufferOverflow = BufferOverf… in <lambda>()
191 …legalArgumentException> { flow.buffer(capacity = Channel.CONFLATED, onBufferOverflow = BufferOverf… in <lambda>()
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
H A DChannelFlow.kt29 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
48 @JvmField public val onBufferOverflow: BufferOverflow constant in kotlinx.coroutines.flow.internal.ChannelFlow
69 …public override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflo… in dropChannelOperators()
75 if (onBufferOverflow != BufferOverflow.SUSPEND) { in dropChannelOperators()
78 newOverflow = onBufferOverflow in dropChannelOperators()
95 newOverflow = this.onBufferOverflow in dropChannelOperators()
97 …newContext == this.context && newCapacity == this.capacity && newOverflow == this.onBufferOverflow) in dropChannelOperators()
102 …protected abstract fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOv… in create()
115 …scope.produce(context, produceCapacity, onBufferOverflow, start = CoroutineStart.ATOMIC, block = c… in create()
130 … if (onBufferOverflow != BufferOverflow.SUSPEND) props.add("onBufferOverflow=$onBufferOverflow") in additionalToStringProps()
[all …]
H A DMerge.kt14 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
15 ) : ChannelFlowOperator<T, R>(flow, context, capacity, onBufferOverflow) { in <lambda>()
16 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in <lambda>()
17 ChannelFlowTransformLatest(transform, flow, context, capacity, onBufferOverflow) in <lambda>()
42 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND
43 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) {
44 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in create()
45 ChannelFlowMerge(flow, concurrency, context, capacity, onBufferOverflow) in create()
80 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in additionalToStringProps()
81 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in additionalToStringProps()
[all …]
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
H A DContext.kt121 public fun <T> Flow<T>.buffer(capacity: Int = BUFFERED, onBufferOverflow: BufferOverflow = BufferOv… in buffer()
125 require(capacity != CONFLATED || onBufferOverflow == BufferOverflow.SUSPEND) { in buffer()
130 var onBufferOverflow = onBufferOverflow in buffer() variable
133 onBufferOverflow = BufferOverflow.DROP_OLDEST in buffer()
137 is FusibleFlow -> fuse(capacity = capacity, onBufferOverflow = onBufferOverflow) in buffer()
138 … else -> ChannelFlowOperatorImpl(this, capacity = capacity, onBufferOverflow = onBufferOverflow) in buffer()
H A DShare.kt140 onBufferOverflow = config.onBufferOverflow in <lambda>()
150 @JvmField val onBufferOverflow: BufferOverflow, constant in kotlinx.coroutines.flow.SharingConfig
168 … onBufferOverflow == BufferOverflow.SUSPEND -> // buffer was configured with suspension in configureSharing()
175 onBufferOverflow = onBufferOverflow, in configureSharing()
184 onBufferOverflow = BufferOverflow.SUSPEND, in configureSharing()
371 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in asSharedFlow()
372 fuseSharedFlow(context, capacity, onBufferOverflow) in asSharedFlow()
380 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in fuse()
381 fuseStateFlow(context, capacity, onBufferOverflow) in fuse()
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
H A DBuilders.kt310 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in channelFlow()
311 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in channelFlow()
312 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in channelFlow()
313 ChannelFlowBuilder(block, context, capacity, onBufferOverflow) in channelFlow()
326 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND
327 ) : ChannelFlowBuilder<T>(block, context, capacity, onBufferOverflow) {
347 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C…
348 CallbackFlowBuilder(block, context, capacity, onBufferOverflow)
H A DSharedFlow.kt276 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in emit()
280 require(replay > 0 || extraBufferCapacity > 0 || onBufferOverflow == BufferOverflow.SUSPEND) { in emit()
281 … extraBufferCapacity must be positive with non-default onBufferOverflow strategy $onBufferOverflow" in emit()
285 return SharedFlowImpl(replay, bufferCapacity, onBufferOverflow) in emit()
315 private val onBufferOverflow: BufferOverflow constant in kotlinx.coroutines.flow.SharedFlowImpl
425 when (onBufferOverflow) { in tryEmitLocked()
709 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in fuse()
710 fuseSharedFlow(context, capacity, onBufferOverflow) in fuse()
731 onBufferOverflow: BufferOverflow in Array()
735 …y == Channel.RENDEZVOUS || capacity == Channel.OPTIONAL_CHANNEL) && onBufferOverflow == BufferOver… in Array()
[all …]
H A 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()
H A DChannels.kt95 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in receiveAsFlow()
96 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in receiveAsFlow()
105 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in receiveAsFlow()
106 ChannelAsFlow(channel, consume, context, capacity, onBufferOverflow) in receiveAsFlow()
/aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
H A DReactiveFlow.kt48 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
49 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in <lambda>()
50 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in <lambda>()
51 PublisherAsFlow(publisher, context, capacity, onBufferOverflow) in <lambda>()
61 if (onBufferOverflow != BufferOverflow.SUSPEND) { in <lambda>()
88 val subscriber = ReactiveSubscriber<T>(capacity, onBufferOverflow, requestSize) in <lambda>()
115 onBufferOverflow: BufferOverflow,
122 …ate val channel = Channel<T>(if (capacity == Channel.RENDEZVOUS) 1 else capacity, onBufferOverflow)
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
H A DChannel.kt784 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND, in Channel()
789 if (onBufferOverflow == BufferOverflow.SUSPEND) in Channel()
792 …ConflatedBufferedChannel(1, onBufferOverflow, onUndeliveredElement) // support buffer overflow wit… in Channel()
795 require(onBufferOverflow == BufferOverflow.SUSPEND) { in Channel()
802 …if (onBufferOverflow == BufferOverflow.SUSPEND) BufferedChannel(CHANNEL_DEFAULT_CAPACITY, onUndeli… in Channel()
803 else ConflatedBufferedChannel(1, onBufferOverflow, onUndeliveredElement) in Channel()
806 … if (onBufferOverflow === BufferOverflow.SUSPEND) BufferedChannel(capacity, onUndeliveredElement) in Channel()
807 else ConflatedBufferedChannel(capacity, onBufferOverflow, onUndeliveredElement) in Channel()
H A DConflatedBufferedChannel.kt20 private val onBufferOverflow: BufferOverflow, constant in kotlinx.coroutines.channels.ConflatedBufferedChannel
24 require(onBufferOverflow !== SUSPEND) { in <lambda>()
33 get() = onBufferOverflow == DROP_OLDEST
56 if (onBufferOverflow === DROP_LATEST) trySendDropLatest(element, isSendOp) in trySend()
H A DProduce.kt120 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND, in produce()
125 val channel = Channel<E>(capacity, onBufferOverflow) in produce()
/aosp_15_r20/frameworks/base/packages/SystemUI/tests/utils/src/com/android/systemui/common/ui/data/repository/
H A DFakeConfigurationRepository.kt36 onBufferOverflow = BufferOverflow.DROP_OLDEST,
41 MutableSharedFlow<Unit>(replay = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
45 MutableSharedFlow<Configuration>(replay = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
/aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
H A DPublisherAsFlowTest.kt226 onBufferOverflow: BufferOverflow, in <lambda>()
251 .buffer(capacity, onBufferOverflow) in <lambda>()
254 val expected = when (onBufferOverflow) { in <lambda>()
/aosp_15_r20/packages/modules/IntentResolver/java/src/com/android/intentresolver/shortcuts/
DShortcutLoader.kt94 onBufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()
97 MutableSharedFlow<ShortcutData?>(replay = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST) in <lambda>()
/aosp_15_r20/frameworks/base/packages/SystemUI/src/com/android/systemui/assist/data/repository/
H A DAssistRepository.kt29 MutableSharedFlow<Int>(replay = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
/aosp_15_r20/external/lottie/lottie-compose/src/main/java/com/airbnb/lottie/compose/
H A DLottieRetrySignal.kt33 private val channel = Channel<Unit>(capacity = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
/aosp_15_r20/packages/providers/MediaProvider/photopicker/src/com/android/photopicker/features/preparemedia/
DMediaPreparerViewModel.kt149 MutableSharedFlow(replay = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
168 onBufferOverflow = BufferOverflow.SUSPEND,
/aosp_15_r20/packages/providers/MediaProvider/photopicker/src/com/android/photopicker/core/events/
DEvents.kt64 Channel<Event>(capacity = 100, onBufferOverflow = BufferOverflow.SUSPEND) { undeliveredEvent in <lambda>()
/aosp_15_r20/frameworks/base/packages/SystemUI/src/com/android/systemui/keyguard/domain/interactor/
H A DKeyguardTransitionInteractor.kt92 onBufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()
229 onBufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()

12345678910>>...13