| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | FlatMapBaseTest.kt | 12 abstract fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> in <lambda>() method in kotlinx.coroutines.flow.FlatMapBaseTest
18 .flatMap { value -> in <lambda>()
36 }.flatMap { value -> in <lambda>()
47 val list = flowOf(1, null, 2).flatMap { in <lambda>()
59 .flatMap { in <lambda>()
76 .flatMap { in <lambda>()
82 .flatMap { in <lambda>()
|
| D | FlatMapMergeBaseTest.kt | 21 }.flatMap { in <lambda>()
43 }.flatMap { in testConcurrentFailure()
74 }.flatMap { in <lambda>()
|
| D | FlatMapConcatTest.kt | 12 …override fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> = flatMapConcat(transfor… in <lambda>() method in kotlinx.coroutines.flow.FlatMapConcatTest
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/ |
| D | ReactorPlaysScrabble.kt | 58 ….flatMap<Map.Entry<Int, LongWrapper>> { map -> Flux.fromIterable<Map.Entry<Int, LongWrapper>>(Iter… in <lambda>()
59 .flatMap(blank) in <lambda>()
65 .flatMap { l -> Flux.just(l <= 2L) } in <lambda>()
71 ….flatMap<Map.Entry<Int, LongWrapper>> { map -> Flux.fromIterable<Map.Entry<Int, LongWrapper>>(Iter… in <lambda>()
72 .flatMap(letterScore) in <lambda>()
90 .flatMap { Stream -> Stream } in <lambda>()
96 .flatMap<Int>(scoreOfALetter) in <lambda>()
109 .flatMap { Stream -> Stream } in <lambda>()
132 ….flatMap<Map.Entry<Int, List<String>>> { map -> Flux.fromIterable<Map.Entry<Int, List<String>>>(It… in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/ |
| D | RxJava2PlaysScrabble.java | 84 .flatMap(blank) in play()
91 .flatMap(l -> Maybe.just(l <= 2L)) ; in play()
97 .flatMap(letterScore) in play()
111 .flatMap(observable -> observable) ; in play()
116 .flatMap(scoreOfALetter) in play()
|
| /external/dagger2/java/dagger/model/ |
| D | BindingGraph.java | 212 return network().outEdges(node).stream().flatMap(instancesOf(DependencyEdge.class)); in dependencyEdgeStream()
246 .flatMap(instancesOf(Binding.class)) in requestingBindings()
258 .flatMap(instancesOf(Binding.class)) in requestedBindings()
270 .flatMap(instancesOf(MaybeBinding.class)) in requestedMaybeMissingBindings()
310 return network().edges().stream().flatMap(instancesOf(DependencyEdge.class)); in dependencyEdgeStream()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | SimpleSendReceiveJvmTest.kt | 22 fun params(): Collection<Array<Any>> = TestChannelKind.values().flatMap { kind -> in <lambda>()
23 listOf(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 100, 1000).flatMap { n -> in <lambda>()
|
| D | ChannelSendReceiveStressTest.kt | 26 listOf(1, 2, 10).flatMap { nSenders -> in <lambda>()
27 listOf(1, 10).flatMap { nReceivers -> in <lambda>()
|
| /external/connectedappssdk/processor/src/main/java/com/google/android/enterprise/connectedapps/processor/ |
| D | Processor.java | 125 .flatMap(i -> i.getEnclosedElements().stream()) in process()
219 .flatMap( in findAllConfigurations()
356 .flatMap(a -> a.providerClassElements().stream()) in findAllCrossProfileMethods()
362 .flatMap( in findAllCrossProfileMethods()
377 foundProviderClasses.stream().flatMap(m -> m.staticTypes().stream()).collect(toSet())); in findAllCrossProfileMethods()
379 newProviderClasses.stream().flatMap(m -> m.staticTypes().stream()).collect(toSet())); in findAllCrossProfileMethods()
383 .flatMap(t -> GeneratorUtilities.findCrossProfileMethodsInClass(t).stream()) in findAllCrossProfileMethods()
|
| D | LateValidator.java | 126 .flatMap(m -> m.allCrossProfileTypes().stream()) in validateConfiguration()
152 .flatMap(m -> getConnectorQualifiedNamesUsedInProviderClass(m).stream()) in getConnectorQualifiedNamesUsedInConfiguration()
188 .flatMap(Streams::stream) in getConnectorQualifiedNamesUsedInProviderClass()
|
| /external/dagger2/java/dagger/internal/codegen/bindinggraphvalidation/ |
| D | DependsOnProductionExecutorValidator.java | 60 .flatMap(instancesOf(MaybeBinding.class)) in visitGraph()
62 .flatMap(productionExecutor -> bindingGraph.requestingBindings(productionExecutor).stream()) in visitGraph()
|
| D | ProvisionDependencyOnProducerBindingValidator.java | 65 .flatMap(binding -> incomingDependencies(binding, bindingGraph)) in provisionDependenciesOnProductionBindings()
74 .flatMap(instancesOf(DependencyEdge.class)); in incomingDependencies()
|
| /external/javaparser/javaparser-core/src/main/java/com/github/javaparser/ |
| D | Problem.java | 93 …final Optional<Position> aBegin= a.getLocation().flatMap(l -> l.getBegin().getRange().map(r -> r.b…
94 …final Optional<Position> bBegin = b.getLocation().flatMap(l -> l.getBegin().getRange().map(r -> r.…
|
| /external/okio/okio/src/jvmTest/java/okio/internal/ |
| D | HmacTest.kt | 41 return algorithms.flatMap { algorithm -> in <lambda>()
42 keySizes.flatMap { keySize -> in <lambda>()
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | StreamsTest.java | 117 .flatMap(x -> x); in testConcat_refStream_closeIsPropagated_Stream_flatMap()
225 elems -> Stream.of((Object) null).flatMap(unused -> ImmutableList.copyOf(elems).stream())); in testMapWithIndex_unsizedSource()
234 Stream.of((Object) null).flatMap(unused -> Stream.of("a", "b", "c"))); in testMapWithIndex_closeIsPropagated_unsizedSource()
259 IntStream.of(0).flatMap(unused -> IntStream.of(1, 2, 3))); in testMapWithIndex_intStream_closeIsPropagated_unsized()
284 LongStream.of(0).flatMap(unused -> LongStream.of(1, 2, 3))); in testMapWithIndex_longStream_closeIsPropagated_unsized()
311 DoubleStream.of(0).flatMap(unused -> DoubleStream.of(1, 2, 3))); in testMapWithIndex_doubleStream_closeIsPropagated_unsized()
|
| D | CollectSpliteratorsTest.java | 44 CollectSpliterators.flatMap( in testFlatMap()
55 CollectSpliterators.flatMap( in testFlatMap_nullStream()
|
| /external/google-java-format/core/src/test/resources/com/google/googlejavaformat/java/testdata/ |
| D | B20128760.input | 99 .flatMap(m -> m.getFieldValues()
103 .flatMap(fv -> FieldDTO.deserializeStringToListOfStrings(fv.getValue())
|
| D | B20128760.output | 93 .flatMap(
97 .flatMap(
|
| D | B124394008.input | 4 readProfileResponse.flatMap(authorExtractor::extract)
|
| D | B124394008.output | 5 .flatMap(authorExtractor::extract)
|
| /external/connectedappssdk/processor/src/main/java/com/google/android/enterprise/connectedapps/processor/containers/ |
| D | CrossProfileConfigurationInfo.java | 72 .flatMap(m -> m.allCrossProfileTypes().stream()) in create()
74 .flatMap(Streams::stream) in create()
|
| D | ParcelableWrapper.java | 97 .flatMap(m -> extractReturnTypeAndParameters(m).stream()) in extractTypesFromMethods()
98 .flatMap(t -> extractTypeArgumentsIfWrapped(t).stream()) in extractTypesFromMethods()
126 .flatMap(t -> extractTypeArgumentsIfWrapped(t).stream()) in extractTypeArgumentsFromGeneric()
|
| /external/desugar/java/com/google/devtools/common/options/ |
| D | OptionValueDescription.java | 281 .flatMap(Collection::stream) in getSourceString()
297 .flatMap(Collection::stream) in getValue()
325 .flatMap(Collection::stream) in getCanonicalInstances()
|
| /external/javaparser/javaparser-symbol-solver-testing/src/test/test_sourcecode/javasymbolsolver_0_6_0/expected_output/java-symbol-solver-core/ |
| D | com_github_javaparser_symbolsolver_javaparsermodel_declarations_JavaParserAnonymousClassDeclaration.txt | 42 …rsOfKind(com.github.javaparser.ast.body.FieldDeclaration.class).stream().flatMap(field -> field.ge…
43 …flatMap(field -> field.getVariables().stream().map(variable -> new JavaParserFieldDeclaration(vari…
53 …Line 123) getInterfaces().stream().flatMap(inteface -> inteface.getTypeDeclaration().getAllFields(…
54 …nterfaces().stream().flatMap(inteface -> inteface.getTypeDeclaration().getAllFields().stream()) ==…
|
| /external/dagger2/java/dagger/android/processor/ |
| D | DuplicateAndroidInjectorsChecker.java | 80 .flatMap(injectorFactoryMap -> graph.requestedBindings(injectorFactoryMap).stream()) in validateMapKeyUniqueness()
134 .flatMap( in mapKey()
|