Home
last modified time | relevance | path

Searched defs:flow (Results 1 – 25 of 140) sorted by relevance

123456

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
DSampleTest.kt17 val flow = flow { in <lambda>() constant
39 val flow = flow { in <lambda>() constant
52 val flow = flow { in <lambda>() constant
77 val flow = flow { in <lambda>() constant
89 val flow = flow<Int?> { in <lambda>() constant
101 val flow = flow { in <lambda>() constant
123 val flow = emptyFlow<Int>().sample(Long.MAX_VALUE) in <lambda>() constant
129 val flow = flowOf(1, 2, 3).sample(Long.MAX_VALUE) in <lambda>() constant
137 val flow = flow { in <lambda>() constant
154 val flow = flow { in <lambda>() constant
[all …]
DDebounceTest.kt16 val flow = flow { in <lambda>() constant
38 val flow = flowOf<Int?>(null).debounce(Long.MAX_VALUE) in <lambda>() constant
45 val flow = flow { in <lambda>() constant
67 val flow = emptyFlow<Int>().debounce(Long.MAX_VALUE) in <lambda>() constant
73 val flow = flowOf(1, 2, 3).debounce(1000) in <lambda>() constant
80 val flow = flow { in <lambda>() constant
106 val flow = flow { in testUpstreamError() constant
124 val flow = flow { in <lambda>() constant
142 val flow = flow { in <lambda>() constant
156 val flow = flow { in <lambda>() constant
[all …]
DTransformLatestTest.kt14 val flow = flowOf(1, 2, 3).transformLatest { value -> in <lambda>() constant
35 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
48 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
59 val flow = flowOf(1, 2, 3, 42, 4) in <lambda>() constant
69 val flow = listOf(1, 2, 3, 4).asFlow() in <lambda>() constant
86 val flow = flow { in <lambda>() constant
109 val flow = flowOf(1, 2).transformLatest { value -> in <lambda>() constant
124 val flow = flowOf(1).transformLatest { value -> in <lambda>() constant
139 val flow = flow { in <lambda>() constant
157 val flow = flowOf(1, 2, 3, 4, 5).transformLatest { emit(it) } in <lambda>() constant
DOnEmptyTest.kt15 val flow = emptyFlow<Int>().onEmpty { emit(1) } in <lambda>() constant
21 val flow = flowOf(1).onEmpty { emit(2) } in <lambda>() constant
27 val flow = flow<Int> { in <lambda>() constant
35 val flow = flow<Int> { in <lambda>() constant
50 val flow = emptyFlow<Int>().onEmpty { in <lambda>() constant
65 val flow = emptyFlow<Int>().onEmpty { in <lambda>() constant
DFlatMapLatestTest.kt14 val flow = flowOf(1, 2, 3).flatMapLatest { value -> in <lambda>() constant
32 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
47 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
61 val flow = listOf(1, 2, 3, 4).asFlow() in <lambda>() constant
80 val flow = flowOf(1, 2).flatMapLatest { value -> in <lambda>() constant
97 val flow = flowOf(1).flatMapLatest { value -> in <lambda>() constant
114 val flow = flow { in <lambda>() constant
134 val flow = flowOf(1, 2, 3, 4, 5).flatMapLatest { flowOf(it) } in <lambda>() constant
DRetryTest.kt14 val flow = flow { in <lambda>() constant
33 val flow = flow { in <lambda>() constant
48 val flow = flow { in <lambda>() constant
61 val flow = flow { in <lambda>() constant
75 val flow = flow { in <lambda>() constant
93 val flow = flow<Int> { in <lambda>() constant
DCatchTest.kt14 val flow = flow { in <lambda>() constant
26 val flow = flow { in <lambda>() constant
39 val flow = flow { in <lambda>() constant
50 val flow = flow { in <lambda>() constant
63 val flow = flow<Int> { in <lambda>() constant
76 val flow = flow<Int> { in <lambda>() constant
94 val flow = flow { in <lambda>() constant
DDistinctUntilChangedTest.kt16 val flow = flowOf(1, 1, 2, 2, 1).distinctUntilChanged() in <lambda>() constant
22 val flow = flow { in <lambda>() constant
37 val flow = flow { in <lambda>() constant
52 val flow = flowOf(1) in <lambda>() constant
59 val flow = flow { in <lambda>() constant
76 val flow = flow { in <lambda>() constant
94 val flow = flowOf(null, 1, null, null).distinctUntilChanged() in <lambda>() constant
120 val flow = (1..10).asFlow() in <lambda>() constant
DFlowOnTest.kt18 val flow = source::produce.asFlow() in <lambda>() constant
44 val flow = source::produce.asFlow() in <lambda>() constant
61 val flow = flow { in <lambda>() constant
79 val flow = flow { in testFlowOnThrowingOperator() constant
96 val flow = flow { in <lambda>() constant
118 val flow = flow { in <lambda>() constant
239 val flow = flow { in <lambda>() constant
253 val flow = flow { in <lambda>() constant
284 val flow = flow { in <lambda>() constant
308 val flow = flow { in <lambda>() constant
[all …]
DTakeTest.kt13 val flow = flow { in <lambda>() constant
32 val flow = flow { in <lambda>() constant
53 val flow = flowOf(1) in testNonPositiveValues() constant
66 val flow = flow { in <lambda>() constant
83 val flow = flow { in <lambda>() constant
102 val flow = flow { in <lambda>() constant
DCombineParametersTestBase.kt15 val flow = combine(flowOf("1"), flowOf(2), flowOf(null)) { a, b, c -> a + b + c } in <lambda>() constant
24 … val flow = combineTransform(flowOf("1"), flowOf(2), flowOf(null)) { a, b, c -> emit(a + b + c) } in <lambda>() constant
30 …val flow = combine(flowOf("1"), flowOf(2), flowOf("3"), flowOf(null)) { a, b, c, d -> a + b + c + … in <lambda>() constant
36 … val flow = combineTransform(flowOf("1"), flowOf(2), flowOf("3"), flowOf(null)) { a, b, c, d -> in <lambda>() constant
44 …val flow = combine(flowOf("1"), flowOf(2), flowOf("3"), flowOf(4.toByte()), flowOf(null)) { a, b, … in <lambda>() constant
52 val flow = in <lambda>() constant
61 val flow = combine(flowOf(1), flowOf("2")) { args: Array<Any?> -> in <lambda>() constant
69 val flow = combine(listOf(flowOf(1), flowOf("2"))) { args: Array<Any?> -> in <lambda>() constant
77 val flow = combine( in <lambda>() constant
90 val flow = combineTransform( in <lambda>() constant
[all …]
DFilterTrivialTest.kt14 val flow = flowOf(1, 2, null) in <lambda>() constant
26 val flow = flowOf("value", 2.0) in <lambda>() constant
33 val flow = flowOf(1, 2, null) in <lambda>() constant
DIndexedTest.kt14 val flow = flowOf(3, 2, 1).withIndex() in <lambda>() constant
20 val flow = emptyFlow<Int>().withIndex() in <lambda>() constant
35 val flow = flow<Int> { in <lambda>() constant
DScanTest.kt14 val flow = flowOf(1, 2, 3, 4, 5) in <lambda>() constant
21 val flow = flowOf(1, 2, 3) in <lambda>() constant
28 val flow = flowOf(null, 2, null, null, null, 5) in <lambda>() constant
43 val flow = flow { in <lambda>() constant
/external/tensorflow/tensorflow/python/autograph/g3doc/reference/
Dcontrol_flow.md12 ### Dispatch rules
75 ### Compound symbols
108 ### Effects of the tracing process
179 ### `if` statements
211 ### `while` statements
281 ### `for` statements
379 ### `break` statements
439 ### `continue` statements
466 ### `return` statements
Dlimitations.md161 #### AutoGraph analyzes code to detect modifications to Python objects
213 #### Modifications of Python objects are not detected across functions
281 #### Modifications of Python objects are not detected in methods
340 #### Variables closed over by lambda functions
401 #### Modifying Python collections in TensorFlow control flow is not allowed
461 #### Python collections of fixed structure are allowed TensorFlow control flow
490 #### Python collections of fixed structure with dynamic index
523 #### Mixing dynamic computations and static shapes
620 #### Consistency of dtype
664 #### Consistency of shape
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/
DChannelFlowTest.kt14 val flow = channelFlow { in <lambda>() constant
24 val flow = channelFlow { in <lambda>() constant
34 val flow = channelFlow { in <lambda>() constant
45 val flow = channelFlow { in <lambda>() constant
59 val flow = channelFlow<Int> { in <lambda>() constant
71 val flow = channelFlow<Int> { in <lambda>() constant
86 val flow = flowOf(1, 2, 3) in <lambda>() constant
93 val flow = flowOf(1, 2, 3) in <lambda>() constant
138 val flow = flowOf(1, 2, 3).bufferWithTimeout() in <lambda>() constant
167 val flow = channelFlow { in <lambda>() constant
[all …]
DChannelBuildersFlowTest.kt19 val flow = channel.consumeAsFlow() in <lambda>() constant
31 val flow = channel.receiveAsFlow() in <lambda>() constant
44 val flow = channel.consumeAsFlow() in <lambda>() constant
59 val flow = channel.receiveAsFlow() in <lambda>() constant
73 val flow = channel.consumeAsFlow() in <lambda>() constant
86 val flow = channel.receiveAsFlow() in <lambda>() constant
94 val flow = channel.consumeAsFlow() in <lambda>() constant
103 val flow = channel.receiveAsFlow() in <lambda>() constant
117 val flow = channel.consumeAsFlow().buffer() // request buffering in <lambda>() constant
165 val flow = channel.asFlow().map { it * it }.drop(1).take(2) in <lambda>() constant
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/terminal/
DFirstTest.kt15 val flow = flowOf(1, 2, 3) in <lambda>() constant
21 val flow = flowOf(null, 1) in <lambda>() constant
29 val flow = flowOf(1, 2, 3) in <lambda>() constant
38 val flow = flow { in <lambda>() constant
67 val flow = flow { in <lambda>() constant
90 val flow = flowOf(1, 2, 3) in <lambda>() constant
96 val flow = flowOf(1, 2, 3) in <lambda>() constant
105 val flow = flow { in <lambda>() constant
140 val flow = flow { in <lambda>() constant
164 val flow = flowOf(instance) in <lambda>() constant
[all …]
DSingleTest.kt14 val flow = flow { in <lambda>() constant
24 val flow = flow { in <lambda>() constant
40 val flow = flow<Int> { in <lambda>() constant
50 val flow = flow { in <lambda>() constant
73 val flow = flowOf(instance) in <lambda>() constant
86 val flow = flow { in <lambda>() constant
DCountTest.kt13 val flow = flowOf(239, 240) in <lambda>() constant
29 val flow = flow<Int> { in <lambda>() constant
39 val flow = flow { in <lambda>() constant
/external/snakeyaml/src/test/java/org/yaml/snakeyaml/extensions/compactnotation/
DCompactConstructorTest.java23 CompactConstructor flow = new CompactConstructor(); in testNoCompactData() local
37 CompactConstructor flow = new CompactConstructor(); in testGetCompactData1() local
46 CompactConstructor flow = new CompactConstructor(); in testGetCompactData2() local
58 CompactConstructor flow = new CompactConstructor(); in testGetCompactData3() local
70 CompactConstructor flow = new CompactConstructor(); in testGetCompactData4() local
80 CompactConstructor flow = new CompactConstructor(); in testGetCompactData5() local
91 CompactConstructor flow = new CompactConstructor(); in testGetCompactData6() local
100 CompactConstructor flow = new CompactConstructor(); in testGetCompactData7() local
/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/
DCombineTwoFlowsBenchmark.kt26 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
32 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
38 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
44 val flow = (1 until size.toLong()).asFlow() in <lambda>() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DExceptionTransparencyTest.kt14 val flow = flow { in <lambda>() constant
31 val flow = flow { in <lambda>() constant
54 val flow = flow<Int> { in <lambda>() constant
/external/adhd/cras/src/server/
Dcras_dsp_ini.h55 struct flow { struct
56 enum port_type type; /* the type of the ports this flow connects to */ argument
65 DECLARE_ARRAY_TYPE(struct flow, flow_array) argument

123456