| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | Migration.kt | 48 public fun <T> Flow<T>.observeOn(context: CoroutineContext): Flow<T> = noImpl() in <lambda>()
72 public fun <T> Flow<T>.publishOn(context: CoroutineContext): Flow<T> = noImpl() in <lambda>()
101 public fun <T> Flow<T>.subscribeOn(context: CoroutineContext): Flow<T> = noImpl() in <lambda>()
113 public fun <T> Flow<T>.onErrorResume(fallback: Flow<T>): Flow<T> = noImpl() in <lambda>()
125 public fun <T> Flow<T>.onErrorResumeNext(fallback: Flow<T>): Flow<T> = noImpl() in <lambda>()
155 public fun <T> Flow<T>.subscribe(): Unit = noImpl() in <lambda>()
164 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit): Unit = noImpl() in <lambda>()
173 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit, onError: suspend (Throwable) -> Unit… in <lambda>()
185 public fun <T, R> Flow<T>.flatMap(mapper: suspend (T) -> Flow<R>): Flow<R> = noImpl() in <lambda>()
196 public fun <T, R> Flow<T>.concatMap(mapper: (T) -> Flow<R>): Flow<R> = noImpl() in <lambda>()
[all …]
|
| D | Builders.kt | 56 public fun <T> flow(@BuilderInference block: suspend FlowCollector<T>.() -> Unit): Flow<T> = SafeFl… in <lambda>()
69 public fun <T> (() -> T).asFlow(): Flow<T> = flow { in <lambda>()
84 public fun <T> (suspend () -> T).asFlow(): Flow<T> = flow { in <lambda>()
91 public fun <T> Iterable<T>.asFlow(): Flow<T> = flow { in <lambda>()
100 public fun <T> Iterator<T>.asFlow(): Flow<T> = flow { in <lambda>()
109 public fun <T> Sequence<T>.asFlow(): Flow<T> = flow { in <lambda>()
124 public fun <T> flowOf(vararg elements: T): Flow<T> = flow { in <lambda>()
133 public fun <T> flowOf(value: T): Flow<T> = flow { in <lambda>()
144 public fun <T> emptyFlow(): Flow<T> = EmptyFlow in emptyFlow()
146 private object EmptyFlow : Flow<Nothing> { in emptyFlow()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Zip.kt | 32 public fun <T1, T2, R> Flow<T1>.combine(flow: Flow<T2>, transform: suspend (a: T1, b: T2) -> R): Fl… in <lambda>()
51 public fun <T1, T2, R> combine(flow: Flow<T1>, flow2: Flow<T2>, transform: suspend (a: T1, b: T2) -… in combine()
72 public fun <T1, T2, R> Flow<T1>.combineTransform( in combine()
73 flow: Flow<T2>, in combine()
75 ): Flow<R> = combineTransformUnsafe(this, flow) { args: Array<*> -> in combine()
100 flow: Flow<T1>, in combineTransform()
101 flow2: Flow<T2>, in combineTransform()
103 ): Flow<R> = combineTransformUnsafe(flow, flow2) { args: Array<*> -> in combineTransform()
115 flow: Flow<T1>, in combine()
116 flow2: Flow<T2>, in combine()
[all …]
|
| D | Merge.kt | 43 public fun <T, R> Flow<T>.flatMapConcat(transform: suspend (value: T) -> Flow<R>): Flow<R> = in <lambda>()
67 public fun <T, R> Flow<T>.flatMapMerge( in <lambda>()
69 transform: suspend (value: T) -> Flow<R> in <lambda>()
70 ): Flow<R> = in <lambda>()
80 public fun <T> Flow<Flow<T>>.flattenConcat(): Flow<T> = flow { in <lambda>()
94 public fun <T> Iterable<Flow<T>>.merge(): Flow<T> { in merge()
118 public fun <T> merge(vararg flows: Flow<T>): Flow<T> = flows.asIterable().merge() in merge()
136 public fun <T> Flow<Flow<T>>.flattenMerge(concurrency: Int = DEFAULT_CONCURRENCY): Flow<T> { in merge()
163 public fun <T, R> Flow<T>.transformLatest(@BuilderInference transform: suspend FlowCollector<R>.(va… in transformLatest()
189 public inline fun <T, R> Flow<T>.flatMapLatest(@BuilderInference crossinline transform: suspend (va… in transformLatest()
[all …]
|
| D | Transform.kt | 20 public inline fun <T> Flow<T>.filter(crossinline predicate: suspend (T) -> Boolean): Flow<T> = tran… in <lambda>()
27 public inline fun <T> Flow<T>.filterNot(crossinline predicate: suspend (T) -> Boolean): Flow<T> = t… in filterNot()
35 public inline fun <reified R> Flow<*>.filterIsInstance(): Flow<R> = filter { it is R } as Flow<R> in <lambda>()
40 public fun <T: Any> Flow<T?>.filterNotNull(): Flow<T> = transform<T?, T> { value -> in filterNotNull()
47 public inline fun <T, R> Flow<T>.map(crossinline transform: suspend (value: T) -> R): Flow<R> = tra… in map()
54 public inline fun <T, R: Any> Flow<T>.mapNotNull(crossinline transform: suspend (value: T) -> R?): … in mapNotNull()
62 public fun <T> Flow<T>.withIndex(): Flow<IndexedValue<T>> = flow { in <lambda>()
72 public fun <T> Flow<T>.onEach(action: suspend (T) -> Unit): Flow<T> = transform { value -> in onEach()
87 public fun <T, R> Flow<T>.scan(initial: R, @BuilderInference operation: suspend (accumulator: R, va… in <lambda>()
108 public fun <T> Flow<T>.runningReduce(operation: suspend (accumulator: T, value: T) -> T): Flow<T> =… in <lambda>()
|
| D | Context.kt | 125 public fun <T> Flow<T>.buffer(capacity: Int = BUFFERED, onBufferOverflow: BufferOverflow = BufferOv… in <lambda>()
147 public fun <T> Flow<T>.buffer(capacity: Int = BUFFERED): Flow<T> = buffer(capacity) in buffer()
187 public fun <T> Flow<T>.conflate(): Flow<T> = buffer(CONFLATED) in buffer()
240 public fun <T> Flow<T>.flowOn(context: CoroutineContext): Flow<T> { in buffer()
257 public fun <T> Flow<T>.cancellable(): Flow<T> = in cancellable()
266 internal interface CancellableFlow<out T> : Flow<T>
271 private class CancellableFlowImpl<T>(private val flow: Flow<T>) : CancellableFlow<T> {
315 public fun <T, R> Flow<T>.flowWith( in flowWith()
318 builder: Flow<T>.() -> Flow<R> in flowWith()
319 ): Flow<R> { in flowWith()
|
| D | Delay.kt | 66 public fun <T> Flow<T>.debounce(timeoutMillis: Long): Flow<T> { in <lambda>()
117 public fun <T> Flow<T>.debounce(timeoutMillis: (T) -> Long): Flow<T> = in debounce()
154 public fun <T> Flow<T>.debounce(timeout: Duration): Flow<T> = in debounce()
204 public fun <T> Flow<T>.debounce(timeout: (T) -> Duration): Flow<T> = in debounce()
209 private fun <T> Flow<T>.debounceInternal(timeoutMillisSelector: (T) -> Long) : Flow<T> = in debounceInternal()
278 public fun <T> Flow<T>.sample(periodMillis: Long): Flow<T> { in sample()
350 public fun <T> Flow<T>.sample(period: Duration): Flow<T> = sample(period.toDelayMillis())
|
| D | Errors.kt | 57 public fun <T> Flow<T>.catch(action: suspend FlowCollector<T>.(cause: Throwable) -> Unit): Flow<T> = in <lambda>()
84 public fun <T> Flow<T>.onErrorCollect( in onErrorCollect()
85 fallback: Flow<T>, in onErrorCollect()
87 ): Flow<T> = catch { e -> in e()
119 public fun <T> Flow<T>.retry( in retry()
122 ): Flow<T> {
129 public fun <T> Flow<T>.retry( in retry()
132 ): Flow<T> {
170 public fun <T> Flow<T>.retryWhen(predicate: suspend FlowCollector<T>.(cause: Throwable, attempt: Lo… in retryWhen()
189 internal suspend fun <T> Flow<T>.catchImpl( in catchImpl()
|
| D | Limit.kt | 20 public fun <T> Flow<T>.drop(count: Int): Flow<T> { in <lambda>()
33 public fun <T> Flow<T>.dropWhile(predicate: suspend (T) -> Boolean): Flow<T> = flow { in <lambda>()
50 public fun <T> Flow<T>.take(count: Int): Flow<T> { in take()
83 public fun <T> Flow<T>.takeWhile(predicate: suspend (T) -> Boolean): Flow<T> = flow { in <lambda>()
116 public fun <T, R> Flow<T>.transformWhile( in transformWhile()
118 ): Flow<R> = in transformWhile()
127 internal suspend inline fun <T> Flow<T>.collectWhile(crossinline predicate: suspend (value: T) -> B… in collectWhile()
|
| D | Distinct.kt | 23 public fun <T> Flow<T>.distinctUntilChanged(): Flow<T> = in <lambda>()
36 public fun <T> Flow<T>.distinctUntilChanged(areEquivalent: (old: T, new: T) -> Boolean): Flow<T> = in distinctUntilChanged()
45 public fun <T, K> Flow<T>.distinctUntilChangedBy(keySelector: (T) -> K): Flow<T> = in distinctUntilChanged()
61 private fun <T> Flow<T>.distinctUntilChangedBy( in distinctUntilChangedBy()
64 ): Flow<T> = when { in distinctUntilChangedBy()
70 private val upstream: Flow<T>,
73 ): Flow<T> {
|
| D | Emitters.kt | 37 public inline fun <T, R> Flow<T>.transform( in <lambda>()
39 ): Flow<R> = flow { // Note: safe flow is used here, because collector is exposed to transform on e… in <lambda>()
48 internal inline fun <T, R> Flow<T>.unsafeTransform( in unsafeTransform()
50 ): Flow<R> = unsafeFlow { // Note: unsafe flow is used here, because unsafeTransform is only for in… in unsafeTransform()
74 public fun <T> Flow<T>.onStart( in onStart()
76 ): Flow<T> = unsafeFlow { // Note: unsafe flow is used here, but safe collector is used to invoke s… in onStart()
144 public fun <T> Flow<T>.onCompletion( in onCompletion()
146 ): Flow<T> = unsafeFlow { // Note: unsafe flow is used here, but safe collector is used to invoke c… in onCompletion()
179 public fun <T> Flow<T>.onEmpty( in onEmpty()
181 ): Flow<T> = unsafeFlow { in onEmpty()
|
| /external/perfetto/test/trace_processor/chrome/ |
| D | scroll_jank_cause_queuing_delay.out | 3 "Browser","CrProcessMain",2918,0,55000,"InputLatency.LatencyInfo.Flow.QueuingDelay.NoJank.BlockingT…
4 …Flow.QueuingDelay.NoJank.BlockingTasksUs.RenderWidgetHostImpl::ForwardTouchEvent-PassthroughTouchE…
5 …putLatency.LatencyInfo.Flow.QueuingDelay.NoJank.BlockingTasksUs.WidgetInputHandlerImpl::DispatchNo…
6 …00,"InputLatency.LatencyInfo.Flow.QueuingDelay.NoJank.BlockingTasksUs.WidgetInputHandlerImpl::Disp…
7 …putLatency.LatencyInfo.Flow.QueuingDelay.NoJank.BlockingTasksUs.WidgetInputHandlerImpl::DispatchNo…
8 "Renderer","Compositor",2918,0,7000,"InputLatency.LatencyInfo.Flow.QueuingDelay.NoJank.BlockingTask…
9 "Renderer","Compositor",2918,0,25000,"InputLatency.LatencyInfo.Flow.QueuingDelay.NoJank.BlockingTas…
10 …mpositor",2918,0,6000,"InputLatency.LatencyInfo.Flow.QueuingDelay.NoJank.BlockingTasksUs.LatencyIn…
11 "Browser","CrProcessMain",2926,1,52000,"InputLatency.LatencyInfo.Flow.QueuingDelay.Jank.BlockingTas…
12 "Browser","CrProcessMain",2926,1,17000,"InputLatency.LatencyInfo.Flow.QueuingDelay.Jank.BlockingTas…
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/api/ |
| D | kotlinx-coroutines-jdk9.api | 2 …public static final fun awaitFirst (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Contin…
3 …public static final fun awaitFirstOrDefault (Ljava/util/concurrent/Flow$Publisher;Ljava/lang/Objec…
4 …public static final fun awaitFirstOrElse (Ljava/util/concurrent/Flow$Publisher;Lkotlin/jvm/functio…
5 …public static final fun awaitFirstOrNull (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/…
6 …public static final fun awaitLast (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Continu…
7 …public static final fun awaitSingle (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Conti…
11 …/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Ljava/util/concurrent/Flow$Publisher;
12 …neContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Ljava/util/concurrent/Flow$Publisher;
16 …public static final fun asFlow (Ljava/util/concurrent/Flow$Publisher;)Lkotlinx/coroutines/flow/Flo…
17 …public static final fun asPublisher (Lkotlinx/coroutines/flow/Flow;)Ljava/util/concurrent/Flow$Pub…
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/ |
| D | FlowInvariantsTest.kt | 17 testBody: suspend (flowFactory: (suspend FlowCollector<T>.() -> Unit) -> Flow<T>) -> Unit in <lambda>()
27 …private fun <T> abstractFlow(block: suspend FlowCollector<T>.() -> Unit): Flow<T> = object : Abstr… in <lambda>()
109 fun Flow<Int>.merge(other: Flow<Int>): Flow<Int> = flow { in <lambda>() method
118 fun Flow<Int>.trickyMerge(other: Flow<Int>): Flow<Int> = flow { in <lambda>() method
136 fun Flow<Int>.merge(other: Flow<Int>): Flow<Int> = channelFlow { in <lambda>() method
143 fun Flow<Int>.trickyMerge(other: Flow<Int>): Flow<Int> = channelFlow { in <lambda>() method
161 fun Flow<Int>.buffer(): Flow<Int> = flow { in <lambda>() method
176 …private fun Flow<Int>.buffer(coroutineContext: CoroutineContext, flow: (suspend FlowCollector<Int>… in <lambda>() method
262 private suspend fun emptyContextTest(block: Flow<Int>.() -> Flow<Int>) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | CombineTest.kt | 18 …abstract fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in <lambda>()
261 …override fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in combineLatest()
265 …override fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in combineLatest()
272 …override fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in combineLatest()
282 …override fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in combineLatest()
292 …override fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in combineLatest()
297 …override fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in combineLatest()
306 …override fun <T1, T2, R> Flow<T1>.combineLatest(other: Flow<T2>, transform: suspend (T1, T2) -> R)… in combineLatest()
|
| D | MergeTest.kt | 13 abstract fun <T> Iterable<Flow<T>>.merge(): Flow<T> in merge()
63 override fun <T> Iterable<Flow<T>>.merge(): Flow<T> = originalMerge() in merge()
67 override fun <T> Iterable<Flow<T>>.merge(): Flow<T> = originalMerge(*toList().toTypedArray()) in merge()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 880 …outines/flow/AbstractFlow : kotlinx/coroutines/flow/CancellableFlow, kotlinx/coroutines/flow/Flow {
886 public abstract interface class kotlinx/coroutines/flow/Flow {
896 public static final fun asFlow (Ljava/lang/Iterable;)Lkotlinx/coroutines/flow/Flow;
897 public static final fun asFlow (Ljava/util/Iterator;)Lkotlinx/coroutines/flow/Flow;
898 public static final fun asFlow (Lkotlin/jvm/functions/Function0;)Lkotlinx/coroutines/flow/Flow;
899 public static final fun asFlow (Lkotlin/jvm/functions/Function1;)Lkotlinx/coroutines/flow/Flow;
900 public static final fun asFlow (Lkotlin/ranges/IntRange;)Lkotlinx/coroutines/flow/Flow;
901 public static final fun asFlow (Lkotlin/ranges/LongRange;)Lkotlinx/coroutines/flow/Flow;
902 public static final fun asFlow (Lkotlin/sequences/Sequence;)Lkotlinx/coroutines/flow/Flow;
903 …tic final fun asFlow (Lkotlinx/coroutines/channels/BroadcastChannel;)Lkotlinx/coroutines/flow/Flow;
[all …]
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/ |
| D | FlowPlaysScrabbleOpt.kt | 9 import kotlinx.coroutines.flow.Flow in <lambda>()
92 … val buildHistoOnScore: (((String) -> Flow<Int>) -> Flow<TreeMap<Int, List<String>>>) = { score -> in <lambda>()
127 public suspend inline fun Flow<Int>.sum(): Int { in asFlow()
139 public suspend inline fun Flow<Int>.max(): Int { in max()
152 public suspend inline fun Flow<Long>.sum(): Long { in sum()
164 …w(private val source: String, private val startIndex: Int, private val endIndex: Int): Flow<Char> {
170 public fun <T> concat(first: Flow<T>, second: Flow<T>): Flow<T> = flow { in <lambda>()
180 public fun <T, R> Flow<T>.flatMapConcatIterable(transformer: (T) -> Iterable<R>): Flow<R> = flow { in <lambda>()
188 …e fun <T> flow(@BuilderInference crossinline block: suspend FlowCollector<T>.() -> Unit): Flow<T> { in flow()
189 return object : Flow<T> { in flow()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/src/ |
| D | Await.kt | 21 public suspend fun <T> Flow.Publisher<T>.awaitFirst(): T = FlowAdapters.toPublisher(this).awaitFirs…
31 public suspend fun <T> Flow.Publisher<T>.awaitFirstOrDefault(default: T): T =
42 public suspend fun <T> Flow.Publisher<T>.awaitFirstOrNull(): T? =
53 public suspend fun <T> Flow.Publisher<T>.awaitFirstOrElse(defaultValue: () -> T): T =
66 public suspend fun <T> Flow.Publisher<T>.awaitLast(): T =
80 public suspend fun <T> Flow.Publisher<T>.awaitSingle(): T =
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/terminal/ |
| D | Reduce.kt | 19 public suspend fun <S, T : S> Flow<T>.reduce(operation: suspend (accumulator: S, value: T) -> S): S… in <lambda>()
39 public suspend inline fun <T, R> Flow<T>.fold( in fold()
55 public suspend fun <T> Flow<T>.single(): T { in single()
70 public suspend fun <T> Flow<T>.singleOrNull(): T? { in singleOrNull()
90 public suspend fun <T> Flow<T>.first(): T { in first()
104 public suspend fun <T> Flow<T>.first(predicate: suspend (T) -> Boolean): T { in first()
122 public suspend fun <T> Flow<T>.firstOrNull(): T? { in firstOrNull()
135 public suspend fun <T> Flow<T>.firstOrNull(predicate: suspend (T) -> Boolean): T? { in firstOrNull()
|
| D | Collect.kt | 30 public suspend fun Flow<*>.collect(): Unit = collect(NopCollector) in collect()
49 public fun <T> Flow<T>.launchIn(scope: CoroutineScope): Job = scope.launch { in collect()
71 public suspend inline fun <T> Flow<T>.collect(crossinline action: suspend (value: T) -> Unit): Unit… in collect()
82 public suspend inline fun <T> Flow<T>.collectIndexed(crossinline action: suspend (index: Int, value… in collectIndexed()
109 public suspend fun <T> Flow<T>.collectLatest(action: suspend (value: T) -> Unit) { in collectLatest()
131 public suspend inline fun <T> FlowCollector<T>.emitAll(flow: Flow<T>): Unit = flow.collect(this)
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelFlowTest.kt | 98 private fun Flow<Int>.mergeTwoCoroutines(other: Flow<Int>): Flow<Int> = channelFlow { in <lambda>() method
107 private fun Flow<Int>.mergeOneCoroutine(other: Flow<Int>): Flow<Int> = channelFlow { in <lambda>() method
118 fun Flow<Int>.bufferWithTimeout(): Flow<Int> = channelFlow { in <lambda>() method
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/ |
| D | TakeBenchmark.kt | 26 private suspend inline fun Flow<Long>.consume() = in <lambda>()
54 public fun <T> Flow<T>.originalTake(count: Int): Flow<T> { in <lambda>()
75 public fun <T> Flow<T>.fastPathTake(count: Int): Flow<T> { in <lambda>()
93 public fun <T> Flow<T>.mergedStateMachineTake(count: Int): Flow<T> { in <lambda>()
|
| D | TakeWhileBenchmark.kt | 25 private suspend inline fun Flow<Long>.consume() = in <lambda>()
45 … private fun <T> Flow<T>.takeWhileDirect(predicate: suspend (T) -> Boolean): Flow<T> = unsafeFlow { in <lambda>()
57 …private fun <T> Flow<T>.takeWhileViaCollectWhile(predicate: suspend (T) -> Boolean): Flow<T> = uns… in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/ |
| D | README.md | 3 Utilities for [Java Flow](https://docs.oracle.com/javase/9/docs/api/java/util/concurrent/Flow.html).
10 Utilities for [Java Flow](https://docs.oracle.com/javase/9/docs/api/java/util/concurrent/Flow.html).
|