| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | SampleTest.kt | 5 package kotlinx.coroutines.flow.operators
9 import kotlinx.coroutines.flow.*
17 val flow = flow { in <lambda>() constant
32 val result = flow.sample(1000).toList() in <lambda>()
39 val flow = flow { in <lambda>() constant
45 assertEquals(1, flow.singleOrNull()) in <lambda>()
52 val flow = flow { in <lambda>() constant
70 val result = flow.sample(500).toList() in <lambda>()
77 val flow = flow { in <lambda>() constant
83 assertEquals("A", flow.single()) in <lambda>()
[all …]
|
| D | DebounceTest.kt | 5 package kotlinx.coroutines.flow
16 val flow = flow { in <lambda>() constant
31 val result = flow.debounce(1000).toList() in <lambda>()
38 val flow = flowOf<Int?>(null).debounce(Long.MAX_VALUE) in <lambda>() constant
39 assertNull(flow.single()) in <lambda>()
45 val flow = flow { in <lambda>() constant
60 val result = flow.debounce(1000).toList() in <lambda>()
67 val flow = emptyFlow<Int>().debounce(Long.MAX_VALUE) in <lambda>() constant
68 assertNull(flow.singleOrNull()) in <lambda>()
73 val flow = flowOf(1, 2, 3).debounce(1000) in <lambda>() constant
[all …]
|
| D | TakeTest.kt | 5 package kotlinx.coroutines.flow
13 val flow = flow { in <lambda>() constant
18 assertEquals(3, flow.take(2).sum()) in <lambda>()
19 assertEquals(3, flow.take(Int.MAX_VALUE).sum()) in <lambda>()
20 assertEquals(1, flow.take(1).single()) in <lambda>()
21 assertEquals(2, flow.drop(1).take(1).single()) in <lambda>()
32 val flow = flow { in <lambda>() constant
39 assertEquals(3, flow.take(2).sum()) in <lambda>()
40 assertEquals(3, flow.take(Int.MAX_VALUE).sum()) in <lambda>()
41 assertEquals(1, flow.take(1).single()) in <lambda>()
[all …]
|
| D | FlatMapLatestTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
14 val flow = flowOf(1, 2, 3).flatMapLatest { value -> in <lambda>() constant
17 assertEquals(listOf(1, 2, 2, 3, 3, 4), flow.toList()) in <lambda>()
22 val list = flow { in <lambda>()
32 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
33 flow.flatMapLatest { in <lambda>()
34 flow { in <lambda>()
47 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
48 flow.flatMapLatest { in <lambda>()
49 flow { in <lambda>()
[all …]
|
| D | RetryTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
14 val flow = flow { in <lambda>() constant
18 val sum = flow.retryWhen { cause, attempt -> in <lambda>()
33 val flow = flow { in <lambda>() constant
38 assertEquals(4, flow.retry(4).sum()) in <lambda>()
40 assertFailsWith<TestException>(flow) in <lambda>()
42 assertFailsWith<TestException>(flow.retry(2)) in <lambda>()
48 val flow = flow { in <lambda>() constant
53 assertEquals(2, flow.retry(1) { it is TestException }.sum()) in <lambda>()
55 assertFailsWith<TestException>(flow.retry(1) { it !is TestException }) in <lambda>()
[all …]
|
| D | FlowOnTest.kt | 5 package kotlinx.coroutines.flow
18 val flow = source::produce.asFlow() in <lambda>() constant
19 flow.flowOn(NamedDispatchers("ctx1")).launchIn(this) { in <lambda>()
26 flow.flowOn(NamedDispatchers("ctx2")).launchIn(this) { in <lambda>()
44 val flow = source::produce.asFlow() in <lambda>() constant
45 flow.map(mapper) in <lambda>()
61 val flow = flow { in <lambda>() constant
72 assertFailsWith<TestException> { flow.single() } in <lambda>()
79 val flow = flow { in testFlowOnThrowingOperator() constant
89 assertFailsWith<TestException>(flow) in testFlowOnThrowingOperator()
[all …]
|
| D | TransformLatestTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
14 val flow = flowOf(1, 2, 3).transformLatest { value -> in <lambda>() constant
18 assertEquals(listOf(1, 2, 2, 3, 3, 4), flow.toList()) in <lambda>()
23 val list = flow { in <lambda>()
35 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
36 flow.transformLatest { in <lambda>()
48 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
49 flow.transformLatest { in <lambda>()
59 val flow = flowOf(1, 2, 3, 42, 4) in <lambda>() constant
60 flow.transformLatest { in <lambda>()
[all …]
|
| D | DistinctUntilChangedTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
16 val flow = flowOf(1, 1, 2, 2, 1).distinctUntilChanged() in <lambda>() constant
17 assertEquals(4, flow.sum()) in <lambda>()
22 val flow = flow { in <lambda>() constant
29 val sum1 = flow.distinctUntilChanged().map { it.i }.sum() in <lambda>()
30 val sum2 = flow.distinctUntilChangedBy(Box::i).map { it.i }.sum() in <lambda>()
37 val flow = flow { in <lambda>() constant
44 val sum1 = flow.distinctUntilChanged().map { it.i }.sum() in <lambda>()
45 val sum2 = flow.distinctUntilChanged { old, new -> old.i == new.i }.map { it.i }.sum() in <lambda>()
52 val flow = flowOf(1) in <lambda>() constant
[all …]
|
| D | CatchTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
14 val flow = flow { in <lambda>() constant
19 assertEquals(42, flow.catch { emit(41) }.sum()) in <lambda>()
20 assertFailsWith<TestException>(flow) in <lambda>()
26 val flow = flow { in <lambda>() constant
33 assertFailsWith<TestException>(flow) in <lambda>()
39 val flow = flow { in <lambda>() constant
44 assertEquals(3, flow.sum()) in <lambda>()
50 val flow = flow { in <lambda>() constant
57 assertFailsWith<TestException>(flow) in <lambda>()
[all …]
|
| D | CombineTest.kt | 5 package kotlinx.coroutines.flow.operators in <lambda>()
8 import kotlinx.coroutines.flow.* in <lambda>()
10 import kotlinx.coroutines.flow.combine as combineOriginal in <lambda>()
11 import kotlinx.coroutines.flow.combineTransform as combineTransformOriginal in <lambda>()
22 val flow = flowOf("a", "b", "c") in <lambda>() constant
24 val list = flow.combineLatest(flow2) { i, j -> i + j }.toList() in <lambda>()
30 val flow = flowOf("a", null, null) in <lambda>() constant
32 val list = flow.combineLatest(flow2) { i, j -> i + j }.toList() in <lambda>()
38 val flow = flowOf("a", "b", "c") in <lambda>() constant
40 val list = flow.combineLatest(flow2) { i, j -> i + j }.toList() in <lambda>()
[all …]
|
| D | OnEmptyTest.kt | 5 package kotlinx.coroutines.flow.operators
8 import kotlinx.coroutines.flow.*
15 val flow = emptyFlow<Int>().onEmpty { emit(1) } in <lambda>() constant
16 assertEquals(1, flow.single()) in <lambda>()
21 val flow = flowOf(1).onEmpty { emit(2) } in <lambda>() constant
22 assertEquals(1, flow.single()) in <lambda>()
27 val flow = flow<Int> { in <lambda>() constant
30 assertFailsWith<TestException>(flow) in <lambda>()
35 val flow = flow<Int> { in <lambda>() constant
41 val job = flow.onEach { expectUnreached() }.launchIn(this) in <lambda>()
[all …]
|
| D | FlatMapMergeTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
17 val flow = (1..100).asFlow().flatMapMerge(concurrency = 2) { value -> in <lambda>() constant
18 flow { in <lambda>()
26 flow.collect { value -> in <lambda>()
45 val flow = flow { in <lambda>() constant
57 flow.collect() in <lambda>()
72 val flow = flow { in <lambda>() constant
76 flow { in <lambda>()
83 assertFailsWith<CancellationException>(flow) in <lambda>()
89 val flow = flow { in <lambda>() constant
[all …]
|
| D | TakeWhileTest.kt | 5 package kotlinx.coroutines.flow
14 val flow = flow { in <lambda>() constant
19 assertEquals(3, flow.takeWhile { true }.sum()) in <lambda>()
20 assertEquals(1, flow.takeWhile { it < 2 }.single()) in <lambda>()
21 assertEquals(2, flow.drop(1).takeWhile { it < 3 }.single()) in <lambda>()
22 assertNull(flow.drop(1).takeWhile { it < 2 }.singleOrNull()) in <lambda>()
34 val flow = flow { in <lambda>() constant
45 assertEquals(1, flow.takeWhile { it < 2 }.single()) in <lambda>()
52 val flow = flow { in <lambda>() constant
63 assertFailsWith<TestException>(flow) in <lambda>()
[all …]
|
| D | ZipTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
67 val f1 = flow<String> { in <lambda>()
72 val f2 = flow<String> { in <lambda>()
83 val f1 = flow<String> { in <lambda>()
101 val f1 = flow<String> { in <lambda>()
109 val f2 = flow<String> { in <lambda>()
121 val f1 = flow { in <lambda>()
130 val f2 = flow { in <lambda>()
153 val f1 = flow { in <lambda>()
160 val f2 = flow { in <lambda>()
[all …]
|
| D | FlatMapMergeBaseTest.kt | 6 package kotlinx.coroutines.flow
15 val flow = flow { in <lambda>() constant
22 if (it == 1) flow { in <lambda>()
24 } else flow<Int> { in <lambda>()
31 assertFailsWith<TestException> { flow.singleOrNull() } in <lambda>()
38 val flow = flow { in testConcurrentFailure() constant
44 if (it == 1) flow<Int> { in testConcurrentFailure()
61 assertFailsWith<TestException>(flow) in testConcurrentFailure()
68 val flow = flow { in <lambda>() constant
75 if (it == 1) flow<Int> { in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/terminal/ |
| D | FirstTest.kt | 5 package kotlinx.coroutines.flow
9 import kotlinx.coroutines.flow.internal.*
15 val flow = flowOf(1, 2, 3) in <lambda>() constant
16 assertEquals(1, flow.first()) in <lambda>()
21 val flow = flowOf(null, 1) in <lambda>() constant
22 assertNull(flow.first()) in <lambda>()
23 assertNull(flow.first { it == null }) in <lambda>()
24 assertEquals(1, flow.first { it != null }) in <lambda>()
29 val flow = flowOf(1, 2, 3) in <lambda>() constant
30 assertEquals(1, flow.first { it > 0 }) in <lambda>()
[all …]
|
| D | SingleTest.kt | 5 package kotlinx.coroutines.flow
14 val flow = flow { in <lambda>() constant
18 assertEquals(239L, flow.single()) in <lambda>()
19 assertEquals(239L, flow.singleOrNull()) in <lambda>()
24 val flow = flow { in <lambda>() constant
28 assertFailsWith<IllegalArgumentException> { flow.single() } in <lambda>()
29 assertNull(flow.singleOrNull()) in <lambda>()
34 assertFailsWith<NoSuchElementException> { flow<Int> {}.single() } in <lambda>()
35 assertNull(flow<Int> {}.singleOrNull()) in <lambda>()
40 val flow = flow<Int> { in <lambda>() constant
[all …]
|
| D | CountTest.kt | 5 package kotlinx.coroutines.flow
13 val flow = flowOf(239, 240) in <lambda>() constant
14 assertEquals(2, flow.count()) in <lambda>()
15 assertEquals(2, flow.count { true }) in <lambda>()
16 assertEquals(1, flow.count { it % 2 == 0}) in <lambda>()
17 assertEquals(0, flow.count { false }) in <lambda>()
29 val flow = flow<Int> { in <lambda>() constant
33 assertFailsWith<TestException> { flow.count() } in <lambda>()
34 assertFailsWith<TestException> { flow.count { false } } in <lambda>()
39 val flow = flow { in <lambda>() constant
[all …]
|
| /external/tensorflow/tensorflow/python/ops/ |
| D | tensor_array_grad.py | 105 flow = op.inputs[2]
108 g = (tensor_array_ops.TensorArray(dtype=dtype, handle=handle, flow=flow,
110 .grad(source=grad_source, flow=flow))
112 return [None, None, w_g.flow]
118 def _TensorArrayWriteGrad(op, flow): argument
133 grad_source = _GetGradSource(flow)
139 flow = array_ops.identity(flow, "write_barrier")
140 g = (tensor_array_ops.TensorArray(dtype=dtype, handle=handle, flow=flow,
142 .grad(source=grad_source, flow=flow))
144 return [None, None, grad, flow]
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelBuildersFlowTest.kt | 5 package kotlinx.coroutines.flow
19 val flow = channel.consumeAsFlow() in <lambda>() constant
20 assertEquals(55, flow.sum()) in <lambda>()
21 assertFailsWith<IllegalStateException> { flow.collect() } in <lambda>()
31 val flow = channel.receiveAsFlow() in <lambda>() constant
32 assertEquals(55, flow.sum()) in <lambda>()
33 assertEquals(emptyList(), flow.toList()) in <lambda>()
44 val flow = channel.consumeAsFlow() in <lambda>() constant
45 assertEquals(15, flow.take(5).sum()) in <lambda>()
48 assertFailsWith<IllegalStateException> { flow.collect() } in <lambda>()
[all …]
|
| D | ChannelFlowTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
14 val flow = channelFlow { in <lambda>() constant
19 assertEquals(listOf(1, 2, 3), flow.toList()) in <lambda>()
24 val flow = channelFlow { in <lambda>() constant
29 assertEquals(listOf(1, 2), flow.toList()) in <lambda>()
34 val flow = channelFlow { in <lambda>() constant
40 assertEquals(listOf(1, 4), flow.toList()) // two elements in the middle got conflated in <lambda>()
45 val flow = channelFlow { in <lambda>() constant
53 assertFailsWith<TestException>(flow) in <lambda>()
59 val flow = channelFlow<Int> { in <lambda>() constant
[all …]
|
| /external/icu/icu4c/source/samples/layout/ |
| D | pflow.c | 113 pf_object *flow; in pf_create() local
126 flow = NEW_ARRAY(pf_object, 1); in pf_create()
128 flow->fParagraphLayout = NULL; in pf_create()
129 flow->fParagraphCount = 0; in pf_create()
130 flow->fParagraphMax = PARA_GROW; in pf_create()
131 flow->fParagraphGrow = PARA_GROW; in pf_create()
132 flow->fLineCount = 0; in pf_create()
133 flow->fLinesMax = LINE_GROW; in pf_create()
134 flow->fLinesGrow = LINE_GROW; in pf_create()
135 flow->fLines = NULL; in pf_create()
[all …]
|
| /external/snakeyaml/src/test/java/org/yaml/snakeyaml/extensions/compactnotation/ |
| D | CompactConstructorTest.java | 23 CompactConstructor flow = new CompactConstructor(); in testNoCompactData() local
24 assertNull(flow.getCompactData("scalar")); in testNoCompactData()
25 assertNull(flow.getCompactData("123")); in testNoCompactData()
26 assertNull(flow.getCompactData("(name=frame,title=My Frame)")); in testNoCompactData()
27 assertNull(flow.getCompactData("JFrame name=frame,title=My Frame)")); in testNoCompactData()
28 assertNull(flow.getCompactData("JFrame name=frame,title=My Frame")); in testNoCompactData()
29 assertNull(flow.getCompactData("JFrame(name=frame,title=My Frame")); in testNoCompactData()
30 assertNull(flow.getCompactData("JFrame(name=frame,title=My Frame)b")); in testNoCompactData()
31 assertNull(flow.getCompactData("JFrame(name=frame,title=My Frame) ")); in testNoCompactData()
32 assertNull(flow.getCompactData("JFrame(name=)")); in testNoCompactData()
[all …]
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/ |
| D | CombineTwoFlowsBenchmark.kt | 5 package benchmarks.flow in <lambda>()
8 import kotlinx.coroutines.flow.* in <lambda>()
9 import kotlinx.coroutines.flow.internal.* in <lambda>()
26 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
27 flow.combine(flow) { a, b -> a + b }.collect() in <lambda>()
32 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
33 flow.combineTransform(flow) { a, b -> emit(a + b) }.collect() in <lambda>()
38 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
39 combine(listOf(flow, flow)) { arr -> arr[0] + arr[1] }.collect() in <lambda>()
44 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/ |
| D | FlowInvariantsTest.kt | 5 package kotlinx.coroutines.flow in <lambda>()
19 val r1 = runCatching { testBody { flow(it) } }.exceptionOrNull() in <lambda>()
40 fun testWithContextContract() = runParametrizedTest<Int>(IllegalStateException::class) { flow -> in <lambda>() method
41 flow { in <lambda>()
51 …WithDispatcherContractViolated() = runParametrizedTest<Int>(IllegalStateException::class) { flow -> in <lambda>() method
52 flow { in <lambda>()
62 …n testWithNameContractViolated() = runParametrizedTest<Int>(IllegalStateException::class) { flow -> in <lambda>() method
63 flow { in <lambda>()
74 val flow = flow { in <lambda>() constant
80 flow in <lambda>()
[all …]
|