Searched refs:onClose (Results 1 – 8 of 8) sorted by relevance
52 ints.onClose(closer); in testOneCloseHandler()58 try (Stream<Integer> ints = countTo(100).stream().onClose(closer)) { in testOneCloseHandler()64 try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(closer)) { in testOneCloseHandler()70 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(closer).filter(e -> tr… in testOneCloseHandler()82 ints.onClose(close1).onClose(close2); in testTwoCloseHandlers()88 try (Stream<Integer> ints = countTo(100).stream().onClose(close1).onClose(close2)) { in testTwoCloseHandlers()94 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testTwoCloseHandlers()100 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testTwoCloseHandlers()114 ints.onClose(close1).onClose(close2).onClose(close3); in testCascadedExceptions()126 …try (Stream<Integer> ints = countTo(100).stream().onClose(close1).onClose(close2).onClose(close3))… in testCascadedExceptions()[all …]
150 S onClose(Runnable closeHandler); in onClose() method
835 return stream.onClose(Streams.composedClose(a, b)); in concat()
853 return stream.onClose(Streams.composedClose(a, b)); in concat()
861 return stream.onClose(Streams.composedClose(a, b)); in concat()
1082 return stream.onClose(Streams.composedClose(a, b)); in concat()
332 public S onClose(Runnable closeHandler) { in onClose() method in AbstractPipeline
3476 .onClose(asUncheckedRunnable(ds));3577 .onClose(iterator::close)3690 .onClose(iterator::close)3746 return br.lines().onClose(asUncheckedRunnable(br));