| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | BufferConflationTest.kt | 20 onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST, in <lambda>()
26 …BufferOverflow.DROP_OLDEST -> listOf(0) + (n - capacity until n).toList() // first item & capacity… in <lambda>()
27 BufferOverflow.DROP_LATEST -> (0..capacity).toList() // first & capacity following ones 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>()
100 checkConflate(1, BufferOverflow.DROP_LATEST) { in <lambda>()
101 buffer(onBufferOverflow = BufferOverflow.DROP_LATEST) in <lambda>()
106 checkConflate(1, BufferOverflow.DROP_LATEST) { in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
| D | ShareInConflationTest.kt | 20 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>()
111 checkConflation(1, BufferOverflow.DROP_LATEST) { in <lambda>()
112 … buffer(onBufferOverflow = BufferOverflow.DROP_LATEST).shareIn(it, SharingStarted.Eagerly, 0) in <lambda>()
[all …]
|
| D | StateInTest.kt | 25 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>()
|
| D | SharedFlowTest.kt | 506 fun testDropLatest() = testDropLatestOrOldest(BufferOverflow.DROP_LATEST) in <lambda>()
509 fun testDropOldest() = testDropLatestOrOldest(BufferOverflow.DROP_OLDEST) in <lambda>()
511 private fun testDropLatestOrOldest(bufferOverflow: BufferOverflow) = runTest { in <lambda>()
522 BufferOverflow.DROP_OLDEST -> 5 in <lambda>()
523 BufferOverflow.DROP_LATEST -> 4 in <lambda>()
685 onBufferOverflow = BufferOverflow.DROP_OLDEST in <lambda>()
760 …egalArgumentException> { MutableSharedFlow<Int>(0, onBufferOverflow = BufferOverflow.DROP_LATEST) } in <lambda>()
761 …egalArgumentException> { MutableSharedFlow<Int>(0, onBufferOverflow = BufferOverflow.DROP_OLDEST) } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | ChannelFlow.kt | 33 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
52 @JvmField public val onBufferOverflow: BufferOverflow
73 …ide fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): Flow<T> { in dropChannelOperators()
78 val newOverflow: BufferOverflow in dropChannelOperators()
79 if (onBufferOverflow != BufferOverflow.SUSPEND) { in dropChannelOperators()
106 …n create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<… in create()
114 BufferOverflow.SUSPEND -> produceCapacity in create()
115 BufferOverflow.DROP_OLDEST -> Channel.CONFLATED in create()
116 BufferOverflow.DROP_LATEST -> in create()
146 … if (onBufferOverflow != BufferOverflow.SUSPEND) props.add("onBufferOverflow=$onBufferOverflow") in additionalToStringProps()
[all …]
|
| D | Merge.kt | 18 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
20 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in <lambda>()
46 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND
48 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in create()
84 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in additionalToStringProps()
86 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in additionalToStringProps()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherAsFlowTest.kt | 188 testRequestSizeWithBuffer(Channel.RENDEZVOUS, BufferOverflow.SUSPEND, 1) in <lambda>()
192 testRequestSizeWithBuffer(1, BufferOverflow.SUSPEND, 1) in <lambda>()
196 testRequestSizeWithBuffer(10, BufferOverflow.SUSPEND, 10) in <lambda>()
200 testRequestSizeWithBuffer(Channel.UNLIMITED, BufferOverflow.SUSPEND, Long.MAX_VALUE) in <lambda>()
204 testRequestSizeWithBuffer(Channel.BUFFERED, BufferOverflow.SUSPEND, 64) in <lambda>()
208 testRequestSizeWithBuffer(Channel.BUFFERED, BufferOverflow.DROP_OLDEST, Long.MAX_VALUE) in <lambda>()
212 testRequestSizeWithBuffer(Channel.BUFFERED, BufferOverflow.DROP_LATEST, Long.MAX_VALUE) in <lambda>()
216 testRequestSizeWithBuffer(10, BufferOverflow.DROP_OLDEST, Long.MAX_VALUE) in <lambda>()
220 testRequestSizeWithBuffer(10, BufferOverflow.DROP_LATEST, Long.MAX_VALUE) in <lambda>()
228 onBufferOverflow: BufferOverflow, in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ChannelFactoryTest.kt | 21 assertTrue(Channel<Int>(Channel.UNLIMITED, BufferOverflow.DROP_OLDEST) is LinkedListChannel) in testLinkedListChannel()
22 assertTrue(Channel<Int>(Channel.UNLIMITED, BufferOverflow.DROP_LATEST) is LinkedListChannel) in testLinkedListChannel()
28 assertTrue(Channel<Int>(1, BufferOverflow.DROP_OLDEST) is ConflatedChannel) in testConflatedChannel()
34 assertTrue(Channel<Int>(1, BufferOverflow.DROP_LATEST) is ArrayChannel) in testArrayChannel()
45 …assertFailsWith<IllegalArgumentException> { Channel<Int>(Channel.CONFLATED, BufferOverflow.DROP_OL… in testUnsupportedBufferOverflow()
46 …assertFailsWith<IllegalArgumentException> { Channel<Int>(Channel.CONFLATED, BufferOverflow.DROP_LA… in testUnsupportedBufferOverflow()
|
| D | ChannelBufferOverflowTest.kt | 13 val c = Channel<Int>(2, BufferOverflow.DROP_LATEST) in <lambda>()
28 val c = Channel<Int>(2, BufferOverflow.DROP_OLDEST) in <lambda>()
|
| D | ConflatedChannelArrayModelTest.kt | 10 ArrayChannel<T>(1, BufferOverflow.DROP_OLDEST, null)
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | Builders.kt | 338 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in channelFlow()
340 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in channelFlow()
354 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND
375 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C…
|
| D | SharedFlow.kt | 206 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in tryEmit()
210 require(replay > 0 || extraBufferCapacity > 0 || onBufferOverflow == BufferOverflow.SUSPEND) { in tryEmit()
245 private val onBufferOverflow: BufferOverflow
349 BufferOverflow.SUSPEND -> return false // will suspend in tryEmitLocked()
350 BufferOverflow.DROP_LATEST -> return true // just drop incoming in tryEmitLocked()
351 BufferOverflow.DROP_OLDEST -> {} // force enqueue & drop oldest instead in tryEmitLocked()
632 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in fuse()
655 onBufferOverflow: BufferOverflow in Array()
659 …ENDEZVOUS || capacity == Channel.OPTIONAL_CHANNEL) && onBufferOverflow == BufferOverflow.SUSPEND) { in Array()
|
| D | Channels.kt | 123 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in receiveAsFlow()
133 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in receiveAsFlow()
|
| D | StateFlow.kt | 358 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in createSlot()
372 onBufferOverflow: BufferOverflow in fuseStateFlow()
376 …if ((capacity in 0..1 || capacity == Channel.BUFFERED) && onBufferOverflow == BufferOverflow.DROP_… in fuseStateFlow()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Channel.kt | 646 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND, in Channel()
651 if (onBufferOverflow == BufferOverflow.SUSPEND) in Channel()
657 require(onBufferOverflow == BufferOverflow.SUSPEND) { in Channel()
664 if (onBufferOverflow == BufferOverflow.SUSPEND) CHANNEL_DEFAULT_CAPACITY else 1, in Channel()
668 if (capacity == 1 && onBufferOverflow == BufferOverflow.DROP_OLDEST) in Channel()
|
| D | Produce.kt | 99 …produce(context, capacity, BufferOverflow.SUSPEND, CoroutineStart.DEFAULT, onCompletion = null, bl… in produce()
121 produce(context, capacity, BufferOverflow.SUSPEND, start, onCompletion, block) in produce()
127 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND, in produce()
|
| D | ArrayChannel.kt | 27 private val onBufferOverflow: BufferOverflow,
50 … isBufferFull: Boolean get() = size.value == capacity && onBufferOverflow == BufferOverflow.SUSPEND
143 BufferOverflow.SUSPEND -> OFFER_FAILED in updateBufferSize()
144 BufferOverflow.DROP_LATEST -> OFFER_SUCCESS in updateBufferSize()
145 BufferOverflow.DROP_OLDEST -> null // proceed, will drop oldest in enqueueElement in updateBufferSize()
156 … assert { onBufferOverflow == BufferOverflow.DROP_OLDEST } // the only way we can get here in enqueueElement()
|
| D | BufferOverflow.kt | 19 public enum class BufferOverflow { class
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Context.kt | 125 …> Flow<T>.buffer(capacity: Int = BUFFERED, onBufferOverflow: BufferOverflow = BufferOverflow.SUSPE… in <lambda>()
129 require(capacity != CONFLATED || onBufferOverflow == BufferOverflow.SUSPEND) { in <lambda>()
137 onBufferOverflow = BufferOverflow.DROP_OLDEST in <lambda>()
|
| D | Share.kt | 154 @JvmField val onBufferOverflow: BufferOverflow,
172 … onBufferOverflow == BufferOverflow.SUSPEND -> // buffer was configured with suspension in configureSharing()
188 onBufferOverflow = BufferOverflow.SUSPEND, in configureSharing()
365 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in asSharedFlow()
372 override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow) = in fuse()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 51 onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND in <lambda>()
53 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in <lambda>()
64 if (onBufferOverflow != BufferOverflow.SUSPEND) { in <lambda>()
118 onBufferOverflow: BufferOverflow,
|
| /external/webrtc/modules/audio_processing/aec3/ |
| D | render_delay_buffer_unittest.cc | 36 TEST(RenderDelayBuffer, BufferOverflow) { in TEST() argument
|
| /external/gwp_asan/gwp_asan/tests/ |
| D | crash_handler_api.cpp | 187 TEST_F(CrashHandlerAPITest, BufferOverflow) { in TEST_F() argument
|
| /external/llvm-project/compiler-rt/lib/gwp_asan/tests/ |
| D | crash_handler_api.cpp | 186 TEST_F(CrashHandlerAPITest, BufferOverflow) { in TEST_F() argument
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 582 public final class kotlinx/coroutines/channels/BufferOverflow : java/lang/Enum {
583 public static final field DROP_LATEST Lkotlinx/coroutines/channels/BufferOverflow;
584 public static final field DROP_OLDEST Lkotlinx/coroutines/channels/BufferOverflow;
585 public static final field SUSPEND Lkotlinx/coroutines/channels/BufferOverflow;
586 public static fun valueOf (Ljava/lang/String;)Lkotlinx/coroutines/channels/BufferOverflow;
587 public static fun values ()[Lkotlinx/coroutines/channels/BufferOverflow;
623 …public static final fun Channel (ILkotlinx/coroutines/channels/BufferOverflow;Lkotlin/jvm/function…
625 …public static synthetic fun Channel$default (ILkotlinx/coroutines/channels/BufferOverflow;Lkotlin/…
912 … buffer (Lkotlinx/coroutines/flow/Flow;ILkotlinx/coroutines/channels/BufferOverflow;)Lkotlinx/coro…
914 …default (Lkotlinx/coroutines/flow/Flow;ILkotlinx/coroutines/channels/BufferOverflow;ILjava/lang/Ob…
[all …]
|