summaryrefslogtreecommitdiff
path: root/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/lambda/newLambda/IDEA126778.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/java-tests/testData/codeInsight/daemonCodeAnalyzer/lambda/newLambda/IDEA126778.java')
-rw-r--r--java/java-tests/testData/codeInsight/daemonCodeAnalyzer/lambda/newLambda/IDEA126778.java27
1 files changed, 27 insertions, 0 deletions
diff --git a/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/lambda/newLambda/IDEA126778.java b/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/lambda/newLambda/IDEA126778.java
new file mode 100644
index 000000000000..d8bdcc0d6c82
--- /dev/null
+++ b/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/lambda/newLambda/IDEA126778.java
@@ -0,0 +1,27 @@
+import java.util.Map;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import static java.util.stream.Collectors.groupingBy;
+import static java.util.stream.Collectors.mapping;
+
+class Test {
+ private static Map<Long, Long> multiDataPointsToPerTxnSummedValue(final Stream<Map.Entry<DateTime, Map<Long, Long>>> stream) {
+ return stream.flatMap(e -> e.getValue().entrySet().stream().map(ex ->
+ new Object() {
+ Long txId = ex.getKey();
+ DataPoint dataPoint = new DataPoint(e.getKey(), ex.getValue());
+ }
+ )).collect(groupingBy(t -> t.txId, mapping(t -> t.dataPoint, Collectors.summingLong(dataPoint -> dataPoint.getValue().longValue()))));
+ }
+
+ static class MultiDataPoint {}
+ static class DateTime {}
+
+ static class DataPoint {
+ DataPoint(DateTime t, Long val) {}
+ public Long getValue() {
+ return null;
+ }
+ }
+} \ No newline at end of file