test/java/util/stream/bootlib/java/util/stream/StreamTestScenario.java

rev 7962 : 8017513: Support for closeable streams
8022237: j.u.s.BaseStream.onClose() has an issue in implementation or requires spec clarification
8022572: Same exception instances thrown from j.u.stream.Stream.onClose() handlers are not listed as suppressed
Summary: BaseStream implements AutoCloseable; Remove CloseableStream and DelegatingStream
Reviewed-by:
Contributed-by: brian.goetz@oracle.com

*** 37,54 ****
   * the same output (modulo allowable differences in ordering).
   */
  @SuppressWarnings({"rawtypes", "unchecked"})
  public enum StreamTestScenario implements OpTestCase.BaseStreamTestScenario {
  
!     STREAM_FOR_EACH(false) {
          <T, U, S_IN extends BaseStream<T, S_IN>>
          void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
              Stream<U> s = m.apply(data.stream());
              if (s.isParallel()) {
                  s = s.sequential();
              }
              s.forEach(b);
          }
      },
  
      // Collec to list
      STREAM_COLLECT(false) {
--- 37,55 ----
   * the same output (modulo allowable differences in ordering).
   */
  @SuppressWarnings({"rawtypes", "unchecked"})
  public enum StreamTestScenario implements OpTestCase.BaseStreamTestScenario {
  
!     STREAM_FOR_EACH_WITH_CLOSE(false) {
          <T, U, S_IN extends BaseStream<T, S_IN>>
          void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) {
              Stream<U> s = m.apply(data.stream());
              if (s.isParallel()) {
                  s = s.sequential();
              }
              s.forEach(b);
+             s.close();
          }
      },
  
      // Collec to list
      STREAM_COLLECT(false) {