| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | StreamCloseTest.java | 47 checkNPE(() -> Stream.of(1).onClose(null)); in testNullCloseHandler()
60 ints.onClose(closer); in testOneCloseHandler()
66 try (Stream<Integer> ints = countTo(100).stream().onClose(closer)) { in testOneCloseHandler()
72 try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(closer)) { in testOneCloseHandler()
78 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(closer).filter(e -> tr… in testOneCloseHandler()
90 ints.onClose(close1).onClose(close2); in testTwoCloseHandlers()
96 try (Stream<Integer> ints = countTo(100).stream().onClose(close1).onClose(close2)) { in testTwoCloseHandlers()
102 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testTwoCloseHandlers()
108 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testTwoCloseHandlers()
122 ints.onClose(close1).onClose(close2).onClose(close3); in testCascadedExceptions()
[all …]
|
| D | FlatMapOpTest.java | 85 AtomicInteger onClose = new AtomicInteger(); in testClose() local
88 before.set(0); onClose.set(0); in testClose()
92 s.get().flatMap(i -> Stream.of(i, i).onClose(onClose::getAndIncrement)).count(); in testClose()
93 assertEquals(before.get(), onClose.get()); in testClose()
95 s.get().flatMapToInt(i -> IntStream.of(i, i).onClose(onClose::getAndIncrement)).count(); in testClose()
96 assertEquals(before.get(), onClose.get()); in testClose()
98 s.get().flatMapToLong(i -> LongStream.of(i, i).onClose(onClose::getAndIncrement)).count(); in testClose()
99 assertEquals(before.get(), onClose.get()); in testClose()
101 … s.get().flatMapToDouble(i -> DoubleStream.of(i, i).onClose(onClose::getAndIncrement)).count(); in testClose()
102 assertEquals(before.get(), onClose.get()); in testClose()
[all …]
|
| D | WhileOpTest.java | 334 Stream<Integer> s = Stream.of(1, 2, 3).onClose(() -> isClosed.set(true));
344 IntStream s = IntStream.of(1, 2, 3).onClose(() -> isClosed.set(true));
354 LongStream s = LongStream.of(1, 2, 3).onClose(() -> isClosed.set(true));
364 DoubleStream s = DoubleStream.of(1, 2, 3).onClose(() -> isClosed.set(true));
|
| D | CollectorsTest.java | 565 … Function<Integer, Stream<Integer>> flatMapper = i -> Stream.of(i, i).onClose(ai::getAndIncrement);
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | DoubleStream.java | 382 isParallel()).onClose(this::close); in takeWhile()
449 isParallel()).onClose(this::close); in dropWhile()
1161 return stream.onClose(Streams.composedClose(a, b)); in concat()
|
| D | IntStream.java | 379 isParallel()).onClose(this::close); in takeWhile()
445 isParallel()).onClose(this::close); in dropWhile()
1154 return stream.onClose(Streams.composedClose(a, b)); in concat()
|
| D | BaseStream.java | 158 S onClose(Runnable closeHandler); in onClose() method
|
| D | LongStream.java | 380 isParallel()).onClose(this::close); in takeWhile()
447 isParallel()).onClose(this::close); in dropWhile()
1158 return stream.onClose(Streams.composedClose(a, b)); in concat()
|
| D | Stream.java | 765 isParallel()).onClose(this::close);
831 isParallel()).onClose(this::close);
1620 return stream.onClose(Streams.composedClose(a, b));
|
| D | AbstractPipeline.java | 332 public S onClose(Runnable closeHandler) { in onClose() method in AbstractPipeline
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | DefaultMethodStreams.java | 377 public Stream<T> onClose(Runnable closeHandler) { in onClose() method in DefaultMethodStreams.DefaultMethodRefStream
378 return s.onClose(closeHandler); in onClose()
583 public IntStream onClose(Runnable closeHandler) { in onClose() method in DefaultMethodStreams.DefaultMethodIntStream
584 return s.onClose(closeHandler); in onClose()
784 public LongStream onClose(Runnable closeHandler) { in onClose() method in DefaultMethodStreams.DefaultMethodLongStream
785 return s.onClose(closeHandler); in onClose()
977 public DoubleStream onClose(Runnable closeHandler) { in onClose() method in DefaultMethodStreams.DefaultMethodDoubleStream
978 return s.onClose(closeHandler); in onClose()
|
| /libcore/ojluni/src/main/java/java/nio/file/ |
| D | Files.java | 3476 .onClose(asUncheckedRunnable(ds));
3577 .onClose(iterator::close)
3690 .onClose(iterator::close)
3746 return br.lines().onClose(asUncheckedRunnable(br));
|
| /libcore/ojluni/src/main/java/java/util/ |
| D | Scanner.java | 2852 return stream.onClose(this::close); in tokens()
2939 return stream.onClose(this::close); in findAll()
|
| /libcore/ojluni/src/test/java/util/stream/Collectors/ |
| D | CollectorsTest.java | 547 … Function<Integer, Stream<Integer>> flatMapper = i -> Stream.of(i, i).onClose(ai::getAndIncrement);
|
| /libcore/api/ |
| D | current.txt | 18168 method public S onClose(Runnable);
|