Java 8 stream.map (): Исключение в потоке "main" java .lang.IllegalStateException: источник уже использован или закрыт

Question

У меня ниже программа, которая:

1. Считывает данные из файла в виде потока.
2. Создайте новый поток, используя stream.map () поверх указанного выше потока, и сохраните его в retVal.
3. Возврат retVal.
4. Вывести значения Stream retval, используя forEach, но я получаю исключение: IllegalStateException: источник уже использован или закрыт
5. Для функции workingPopulateFromFileAsStream Я явно преобразовал его снова в поток, а затем он работает нормально.

Содержимое файла student.txt:

Name101,Last101
Name102,Last102
Name103,Last103
Name104,Last104
Name105,Last105
Name106,Last106
Name107,Last107
Name108,Last108
Name109,Last109
Name110,Last110

ClientMainApp. java:

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;

class Student {
  String first_name;
  String last_name;

  public Student(String first_name, String last_name) {
    this.first_name = first_name;
    this.last_name = last_name;
  }

  public String toString() {
    return this.first_name + " " + this.last_name;
  }
}

public class ClientMainApp {
  public static void main(String... args) {
    String fileName = "student.txt";
    ClientMainApp obj = new ClientMainApp();

    //Working Code.
    Stream<Student> students_stream = obj.workingPopulateFromFileAsStream(fileName);
    System.out.println("working: Got Student Stream as " + students_stream);
    students_stream.forEach(System.out::println);
    System.out.println("==================================================");

    // Not Working Code.
    Stream<Student> students_stream2 = obj.populateFromFileAsStream2(fileName);
    System.out.println("notWorking: Got Student Stream2 as " + students_stream2);
    students_stream2.forEach(System.out::println);
  }

  private Stream<Student> workingPopulateFromFileAsStream(String fileName) {
    try (Stream<String> stream = Files.lines(Paths.get(fileName))) {
      System.out.println("Working: Got File    Stream as " + stream);
      Stream<Student> retval =
          stream
              .map(
                  st -> {
                    ArrayList<String> record = new ArrayList<>(Arrays.asList(st.split(",")));
                    return new Student(record.get(0), record.get(1));
                  })
              .collect(Collectors.toList()).stream(); // This is the code making the difference.
      System.out.println("Working: Got Retval  Stream as " + retval);
      return retval;
    } catch (IOException e) {
      e.printStackTrace();
    }
    return null;
  }

  private Stream<Student> populateFromFileAsStream2(String fileName) {
    try (Stream<String> stream = Files.lines(Paths.get(fileName))) {
      System.out.println("NotWorking: Got File    Stream  as " + stream);
      Stream<Student> retval =
          stream.map(
              st -> {
                ArrayList<String> record = new ArrayList<>(Arrays.asList(st.split(",")));
                return new Student(record.get(0), record.get(1));
              });
      System.out.println("NotWorking: got Retval  Stream  as " + retval);
      return retval;
    } catch (IOException e) {
      e.printStackTrace();
    }
    return null;
  }
}

Я получаю результат как:

Working: Got File    Stream as java.util.stream.ReferencePipeline$Head@3e3abc88
Working: Got Retval  Stream as java.util.stream.ReferencePipeline$Head@214c265e
working: Got Student Stream as java.util.stream.ReferencePipeline$Head@214c265e
Name101 Last101
Name102 Last102
Name103 Last103
Name104 Last104
Name105 Last105
Name106 Last106
Name107 Last107
Name108 Last108
Name109 Last109
Name110 Last110
==================================================
NotWorking: Got File    Stream  as java.util.stream.ReferencePipeline$Head@7699a589
NotWorking: got Retval  Stream  as java.util.stream.ReferencePipeline$3@4dd8dc3
notWorking: Got Student Stream2 as java.util.stream.ReferencePipeline$3@4dd8dc3
Exception in thread "main" java.lang.IllegalStateException: source already consumed or closed
    at java.util.stream.AbstractPipeline.sourceSpliterator(AbstractPipeline.java:406)
    at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
    at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418)
    at ClientMainApp.main(ClientMainApp.java:38)

Здесь, в ответе, мы можем видеть, что объект потока одинаков для retVal и вернулся к вызывающему функция, но я не уверен, почему он говорит, что он уже используется.

Обратите внимание, что если я использую forEach l oop, внутри populateFromFileAsStream2, то он работает нормально. Это только когда значение возвращается из функции, это выдает ошибку.

Answer 1

Ваша нерабочая версия по сути выглядит следующим образом:

public Stream<String> foo(Path file) throws IOException {
  try (Stream<String> stream = Files.lines(file)) {
    return stream.map(...);
  }
}

Вы используете оператор try-with-resources . Это означает, что Stream закрывается сразу после выхода из блока try, что должно произойти для возврата метода. Таким образом, вы закрываете поток перед возвратом из метода. Тем не менее, я думаю, что ваша ошибка коренится в:

Создайте новый поток с помощью stream.map () поверх указанного выше потока и сохраните его в retVal.

Хотя верно, что map вернет новый объект Stream новый объект все еще является частью того же концептуального потока / конвейера. Другими словами, закрытие ссылки stream аналогично закрытию ссылки retVal. Ваш рабочий код решает эту проблему, возвращая совершенно новый конвейер, но за счет буферизации всего файла в памяти.