Searched refs:close1 (Results 1 – 1 of 1) sorted by relevance
86 Runnable close1 = () -> { holder[0] = true; }; in testTwoCloseHandlers() local90 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()117 Runnable close1 = () -> { holder[0] = true; throw new RuntimeException("1"); }; in testCascadedExceptions() local122 ints.onClose(close1).onClose(close2).onClose(close3); in testCascadedExceptions()134 …try (Stream<Integer> ints = countTo(100).stream().onClose(close1).onClose(close2).onClose(close3))… in testCascadedExceptions()146 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testCascadedExceptions()158 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testCascadedExceptions()