How does combiner in Stream.collect method work in java 8?

by

First off, there is no need for the combiner to be executed in a non-parallel stream since there is nothing to combine.

Secondly, your issue stems from using String::new and String.concat. The accumulator is supposed to modify the first argument by combining the second argument with it but since strings in Java are immutable your code will produce nothing.

          res=res.concat(" ").concat(elem);

will create a new string and then throw away it. You want to use a StringBuilder instead so you can keep the intermediate results:

public static void main(String[] args) {
    List<String> list2 = Arrays.asList("adf", "bcd", "abc", "hgr", "jyt", "edr", "biu");

    String collect = list2.stream().collect(StringBuilder::new, (res, elem) -> {
        res.append(" ").append(elem);
    }, (res1, res2) -> {
        res1.append(res2.toString());
        System.out.printf("res1=%s, res2=%s\n", res1, res2);
    }).toString();
    System.out.println("collect=" + collect);
}

This will also work correctly with a parallel stream

res1= hgr jyt, res2= jyt
res1= bcd abc, res2= abc
res1= adf bcd abc, res2= bcd abc
res1= edr biu, res2= biu
res1= hgr jyt edr biu, res2= edr biu
res1= adf bcd abc hgr jyt edr biu, res2= hgr jyt edr biu
collect= adf bcd abc hgr jyt edr biu

More Related Contents:

  1. How to convert to Java 8 map grouping by Map [closed]
  2. Java 8 List into Map
  3. Collection to stream to a new collection
  4. How to convert a Java 8 Stream to an Array?
  5. How to sum a list of integers with java streams?
  6. Java 8 stream’s .min() and .max(): why does this compile?
  7. Why does Stream not implement Iterable?
  8. How can I create a stream from an array?
  9. In Java 8, is there a ByteStream class?
  10. Sum values from specific field of the objects in a list
  11. Does Stream.forEach respect the encounter order of sequential streams?
  12. Most efficient way to get the last element of a stream
  13. Why does findFirst() throw a NullPointerException if the first element it finds is null?
  14. Sort map by value using lambdas and streams
  15. Java 8 Stream IllegalStateException: Stream has already been operated on or closed
  16. Equivalent of Scala dropWhile
  17. Modifying Objects within stream in Java8 while iterating
  18. Take every nth element from a Java 8 stream
  19. How to sum values in a Map with a stream?
  20. Static context cannot access non-static in Collectors
  21. What Java 8 Stream.collect equivalents are available in the standard Kotlin library?
  22. How to check if exists any duplicate in Java 8 Streams?
  23. Finding enum value with Java 8 Stream API
  24. Java 8, how can I implement a switch statement using streams?
  25. Picking elements of a list until condition is met with Java 8 Lambdas
  26. BigDecimal summary statistics
  27. Does collect operation on Stream close the stream and underlying resources?
  28. How to get multiple values from an object using a single stream operation?
  29. Java8 Lambda: concat list [duplicate]
  30. non-interference requirement on Java 8 streams

Leave a Comment