Java 8 Stream, getting head and tail

by

Even if you hadn’t the problem that you can’t split an IntStream, you code didn’t work because you are invoking your sieve method recursively instead of lazily. So you had an infinity recursion before you could query your resulting stream for the first value.

Splitting an IntStream s into a head and a tail IntStream (which has not yet consumed) is possible:

PrimitiveIterator.OfInt it = s.iterator();
int head = it.nextInt();
IntStream tail = IntStream.generate(it::next).filter(i -> i % head != 0);

At this place you need a construct of invoking sieve on the tail lazily. Stream does not provide that; concat expects existing stream instances as arguments and you can’t construct a stream invoking sieve lazily with a lambda expression as lazy creation works with mutable state only which lambda expressions do not support. If you don’t have a library implementation hiding the mutable state you have to use a mutable object. But once you accept the requirement of mutable state, the solution can be even easier than your first approach:

IntStream primes = from(2).filter(i -> p.test(i)).peek(i -> p = p.and(v -> v % i != 0));

IntPredicate p = x -> true;

IntStream from(int n)
{
  return IntStream.iterate(n, m -> m + 1);
}

This will recursively create a filter but in the end it doesn’t matter whether you create a tree of IntPredicates or a tree of IntStreams (like with your IntStream.concat approach if it did work). If you don’t like the mutable instance field for the filter you can hide it in an inner class (but not in a lambda expression…).

More Related Contents:

  1. Equivalent of Scala dropWhile
  2. Collection to stream to a new collection
  3. How to convert a Java 8 Stream to an Array?
  4. In Java, what are the advantages of streams over loops? [closed]
  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. Files.walk(), calculate total size
  12. Does Stream.forEach respect the encounter order of sequential streams?
  13. Most efficient way to get the last element of a stream
  14. Why does findFirst() throw a NullPointerException if the first element it finds is null?
  15. Sort map by value using lambdas and streams
  16. Java 8 Stream IllegalStateException: Stream has already been operated on or closed
  17. Why does Stream.allMatch() return true for an empty stream?
  18. Modifying Objects within stream in Java8 while iterating
  19. Take every nth element from a Java 8 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. Java 8, how can I implement a switch statement using streams?
  24. BigDecimal summary statistics
  25. In Java 8 how do I transform a Map to another Map using a lambda?
  26. Does collect operation on Stream close the stream and underlying resources?
  27. How to get multiple values from an object using a single stream operation?
  28. Java8 Lambda: concat list [duplicate]
  29. non-interference requirement on Java 8 streams
  30. What is the difference between intermediate and terminal operations?

Leave a Comment