| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | FlatMapBaseTest.kt | 9 abstract fun <T> Flow<T>.flatMap(mapper: suspend (T) -> Flow<T>): Flow<T> in <lambda>() method in kotlinx.coroutines.flow.FlatMapBaseTest
15 .flatMap { value -> in <lambda>()
33 }.flatMap { value -> in <lambda>()
44 val list = flowOf(1, null, 2).flatMap { in <lambda>()
56 .flatMap { in <lambda>()
73 .flatMap { in <lambda>()
79 .flatMap { in <lambda>()
|
| D | FlatMapMergeBaseTest.kt | 17 }.flatMap { in <lambda>()
39 }.flatMap { in testConcurrentFailure()
70 }.flatMap { in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/ |
| D | ReactorPlaysScrabble.kt | 54 ….flatMap<Map.Entry<Int, LongWrapper>> { map -> Flux.fromIterable<Map.Entry<Int, LongWrapper>>(Iter… in <lambda>()
55 .flatMap(blank) in <lambda>()
61 .flatMap { l -> Flux.just(l <= 2L) } in <lambda>()
67 ….flatMap<Map.Entry<Int, LongWrapper>> { map -> Flux.fromIterable<Map.Entry<Int, LongWrapper>>(Iter… in <lambda>()
68 .flatMap(letterScore) in <lambda>()
86 .flatMap { Stream -> Stream } in <lambda>()
92 .flatMap<Int>(scoreOfALetter) in <lambda>()
105 .flatMap { Stream -> Stream } in <lambda>()
128 ….flatMap<Map.Entry<Int, List<String>>> { map -> Flux.fromIterable<Map.Entry<Int, List<String>>>(It… in <lambda>()
|
| /external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/rules/ |
| D | TraversingVisitor.java | 16 .flatMap(this::handleRule); in visitRuleset()
46 return rules.stream().flatMap(subrule -> subrule.accept(this)); in visitTreeRule()
56 .flatMap(map -> map.getValue().accept(this)) in visitEndpoint()
61 return conditions.stream().flatMap(c -> c.getFn().accept(this)); in visitConditions()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/waiters/ |
| D | WaiterConfiguration.java | 39 …configuration.flatMap(WaiterOverrideConfiguration::backoffStrategy).orElse(DEFAULT_BACKOFF_STRATEG… in WaiterConfiguration()
40 … this.waitTimeout = configuration.flatMap(WaiterOverrideConfiguration::waitTimeout).orElse(null); in WaiterConfiguration()
41 …this.maxAttempts = configuration.flatMap(WaiterOverrideConfiguration::maxAttempts).orElse(DEFAULT_… in WaiterConfiguration()
|
| /external/leakcanary2/leakcanary-android-core/src/androidTest/java/leakcanary/ |
| D | DatabaseMigrationTest.kt | 43 .flatMap { analysis -> in <lambda>()
46 .flatMap { leak -> in <lambda>()
73 .flatMap { analysis -> in <lambda>()
76 .flatMap { leak -> in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/ |
| D | RxJava2PlaysScrabble.java | 80 .flatMap(blank) in play()
87 .flatMap(l -> Maybe.just(l <= 2L)) ; in play()
93 .flatMap(letterScore) in play()
107 .flatMap(observable -> observable) ; in play()
112 .flatMap(scoreOfALetter) in play()
|
| /external/dagger2/java/dagger/internal/codegen/binding/ |
| D | BindingGraphTransformations.java | 61 .flatMap(instancesOf(BindingNode.class)) in withFixedBindingTypes()
74 .flatMap(binding -> network.successors(binding).stream()) in withFixedBindingTypes()
75 .flatMap(instancesOf(BindingNode.class)) in withFixedBindingTypes()
91 .flatMap(instancesOf(BindingNode.class)) in bindingsWithMissingBindingTypes()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/retry/ |
| D | RetryMode.java | 155 .flatMap(Resolver::fromString); in fromSystemSettings()
163 .flatMap(p -> p.property(ProfileProperty.RETRY_MODE)) in fromProfileFile()
164 .flatMap(Resolver::fromString); in fromProfileFile()
|
| /external/dagger2/java/dagger/model/ |
| D | BindingGraph.java | 211 return network().outEdges(node).stream().flatMap(instancesOf(DependencyEdge.class)); in dependencyEdgeStream()
245 .flatMap(instancesOf(Binding.class)) in requestingBindings()
257 .flatMap(instancesOf(Binding.class)) in requestedBindings()
269 .flatMap(instancesOf(MaybeBinding.class)) in requestedMaybeMissingBindings()
309 return network().edges().stream().flatMap(instancesOf(DependencyEdge.class)); in dependencyEdgeStream()
|
| /external/dagger2/java/dagger/internal/codegen/model/ |
| D | BindingGraph.java | 210 return network().outEdges(node).stream().flatMap(instancesOf(DependencyEdge.class)); in dependencyEdgeStream()
244 .flatMap(instancesOf(Binding.class)) in requestingBindings()
256 .flatMap(instancesOf(Binding.class)) in requestedBindings()
268 .flatMap(instancesOf(MaybeBinding.class)) in requestedMaybeMissingBindings()
308 return network().edges().stream().flatMap(instancesOf(DependencyEdge.class)); in dependencyEdgeStream()
|
| /external/aws-sdk-java-v2/codegen-lite/src/main/java/software/amazon/awssdk/codegen/lite/regions/ |
| D | EndpointTagGenerator.java | 92 … .flatMap(p -> p.getServices().values().stream()) in endpointTags()
93 … .flatMap(s -> s.getEndpoints().values().stream()); in endpointTags()
95 … .flatMap(p -> p.getServices().values().stream()) in endpointTags()
101 .flatMap(e -> e.getVariants().stream()) in endpointTags()
102 .flatMap(v -> v.getTags().stream()) in endpointTags()
|
| /external/dagger2/java/dagger/spi/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 | 19 fun params(): Collection<Array<Any>> = TestChannelKind.values().flatMap { kind -> in <lambda>()
20 listOf(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 100, 1000).flatMap { n -> in <lambda>()
|
| /external/TestParameterInjector/src/main/java/com/google/testing/junit/testparameterinjector/ |
| D | TestParameterAnnotationMethodProcessor.java | 337 .flatMap(c -> stream(c.getDeclaredFields())) in getAnnotationTypeOrigins()
338 .flatMap(field -> stream(field.getAnnotations())), in getAnnotationTypeOrigins()
343 .flatMap(method -> stream(method.getAnnotations())), in getAnnotationTypeOrigins()
348 .flatMap(method -> stream(method.getParameterAnnotations()).flatMap(Stream::of)), in getAnnotationTypeOrigins()
356 .flatMap(constructor -> stream(constructor.getAnnotations())), in getAnnotationTypeOrigins()
361 .flatMap( in getAnnotationTypeOrigins()
363 stream(constructor.getParameterAnnotations()).flatMap(Stream::of)), in getAnnotationTypeOrigins()
410 .flatMap(x -> x) in getAnnotationTypeOrigins()
743 .flatMap(x -> x) in getAnnotationValuesForUsedAnnotationTypes()
751 .flatMap(List::stream) in getAnnotationValuesForUsedAnnotationTypes()
[all …]
|
| D | PluggableTestRunner.java | 178 .flatMap(annotation -> getTestClass().getAnnotatedMethods(annotation).stream()) in computeTestMethods()
179 .flatMap(method -> processMethod(method).stream()); in computeTestMethods()
241 .flatMap( in processMethod()
304 .flatMap(x -> x) in withRules()
354 .flatMap(annotation -> getTestClass().getAnnotatedMethods(annotation).stream()) in validateTestMethods()
|
| /external/ksp/test-utils/src/main/kotlin/com/google/devtools/ksp/processor/ |
| D | BackingFieldProcessor.kt | 33 results = listOf("lib", "main").flatMap { pkg -> in <lambda>()
35 .flatMap { declaration -> in <lambda>()
|
| D | TopLevelMemberProcessor.kt | 34 results = listOf("lib", "main").flatMap { pkg -> in <lambda>()
36 .flatMap { declaration -> in <lambda>()
|
| /external/jazzer-api/src/main/java/com/code_intelligence/jazzer/mutation/mutator/proto/ |
| D | MessageMutatorFactory.java | 39 .flatMap(messageClass in tryCreate()
43 .flatMap(builderClass in tryCreate()
|
| /external/connectedappssdk/processor/src/main/java/com/google/android/enterprise/connectedapps/processor/ |
| D | Processor.java | 122 .flatMap(i -> i.getEnclosedElements().stream()) in process()
214 .flatMap( in findAllConfigurations()
351 .flatMap(a -> a.providerClassElements().stream()) in findAllCrossProfileMethods()
357 .flatMap( in findAllCrossProfileMethods()
372 foundProviderClasses.stream().flatMap(m -> m.staticTypes().stream()).collect(toSet())); in findAllCrossProfileMethods()
374 newProviderClasses.stream().flatMap(m -> m.staticTypes().stream()).collect(toSet())); in findAllCrossProfileMethods()
378 .flatMap(t -> GeneratorUtilities.findCrossProfileMethodsInClass(t).stream()) in findAllCrossProfileMethods()
|
| /external/trusty/arm-trusted-firmware/tools/conventional-changelog-tf-a/ |
| D | index.js | 57 return sections.flatMap(section => {
72 return (sections || []).flatMap(section => {
106 return (sections || []).flatMap(section => {
|
| /external/arm-trusted-firmware/tools/conventional-changelog-tf-a/ |
| D | index.js | 57 return sections.flatMap(section => {
72 return (sections || []).flatMap(section => {
106 return (sections || []).flatMap(section => {
|
| /external/dagger2/java/dagger/internal/codegen/bindinggraphvalidation/ |
| D | DependsOnProductionExecutorValidator.java | 62 .flatMap(instancesOf(MaybeBinding.class)) in visitGraph()
64 .flatMap(productionExecutor -> bindingGraph.requestingBindings(productionExecutor).stream()) in visitGraph()
|
| /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/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/util/ |
| D | SignerOverrideUtils.java | 66 .flatMap(RequestOverrideConfiguration::signer); in isSignerOverridden()
76 .flatMap(config -> config.signer() in overrideSigner()
|