Stream.flatMap() consumes entire flatmapped stream when Stream.iterator() is called

XMLWordPrintable

    • Type: Bug
    • Resolution: Won't Fix
    • Priority: P4
    • None
    • Affects Version/s: 11.0.9.1, 16, 17
    • Component/s: core-libs

      Following up on https://bugs.openjdk.java.net/browse/JDK-8075939, there's still a case where Stream.flatMap() doesn't get short circuited, when using Stream.iterator():

      // --------------------------------------------------------
      Iterator<Integer> it =
          Stream.of("a", "b")
              .flatMap(s -> Stream
                  .of(1, 2, 3, 4)
                  .filter(i -> { System.out.println(i); return true; }))
              .iterator();

      it.hasNext(); // This consumes the entire flatmapped stream
      it.next();
      // --------------------------------------------------------

      The above program prints:

      1
      2
      3
      4

      This program never stops:

      // --------------------------------------------------------
      Iterator<Integer> it =
          Stream.of("a", "b")
              .flatMap(s -> Stream
                  .iterate(1, i -> i)
                  .filter(i -> { System.out.println(i); return true; }))
              .iterator();

      it.hasNext();
      it.next();
      // --------------------------------------------------------

            Assignee:
            Paul Sandoz
            Reporter:
            Lukas Eder
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

              Created:
              Updated:
              Resolved: