Searched refs:close1 (Results 1 – 1 of 1) sorted by relevance
78 Runnable close1 = () -> { holder[0] = true; }; in testTwoCloseHandlers() local82 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()109 Runnable close1 = () -> { holder[0] = true; throw new RuntimeException("1"); }; in testCascadedExceptions() local114 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()138 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testCascadedExceptions()150 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testCascadedExceptions()