Collect successive pairs from a stream

by

The Java 8 streams library is primarily geared toward splitting streams into smaller chunks for parallel processing, so stateful pipeline stages are quite limited, and doing things like getting the index of the current stream element and accessing adjacent stream elements are not supported.

A typical way to solve these problems, with some limitations, of course, is to drive the stream by indexes and rely on having the values being processed in some random-access data structure like an ArrayList from which the elements can be retrieved. If the values were in arrayList, one could generate the pairs as requested by doing something like this:

    IntStream.range(1, arrayList.size())
             .mapToObj(i -> new Pair(arrayList.get(i-1), arrayList.get(i)))
             .forEach(System.out::println);

Of course the limitation is that the input cannot be an infinite stream. This pipeline can be run in parallel, though.

More Related Contents:

  1. Limit a stream by a predicate
  2. Custom thread pool in Java 8 parallel stream
  3. Word frequency count Java 8
  4. Java 8: performance of Streams vs Collections
  5. Find first element by predicate
  6. Why are Java Streams once-off?
  7. Retrieving a List from a java.util.stream.Stream in Java 8
  8. Reverse a comparator in Java 8
  9. Why is a combiner needed for reduce method that converts type in java 8
  10. Is this a bug in Files.lines(), or am I misunderstanding something about parallel streams?
  11. Can a Collector’s combiner function ever be used on sequential streams?
  12. Java 8: How do I work with exception throwing methods in streams?
  13. Java 8 method references: provide a Supplier capable of supplying a parameterized result
  14. Why does Iterable not provide stream() and parallelStream() methods?
  15. Java Streams: How to do an efficient “distinct and sort”?
  16. stream on JPA lazy list
  17. Java 8 Stream, getting head and tail
  18. How does combiner in Stream.collect method work in java 8?
  19. How can I throw CHECKED exceptions from inside Java 8 lambdas/streams?
  20. How to apply multiple predicates to a java.util.Stream?
  21. Parallel stream from a HashSet doesn’t run in parallel
  22. How to short-circuit a reduce() operation on a Stream?
  23. How to get a Stream from a float[]
  24. Why is Files.list() parallel stream performing so much slower than using Collection.parallelStream()?
  25. Difference between findAny() and findFirst() in Java 8
  26. Want to create a stream of characters from char array in java
  27. How to compare two Streams in Java 8
  28. Non-interference exact meaning in Java 8 streams
  29. Cartesian product of streams in Java 8 as stream (using streams only)
  30. Why does this stream return no element?

Leave a Comment