(final Function<Throwable, ? extends Future<T>> f)
| 726 | } |
| 727 | |
| 728 | @Override |
| 729 | public final Future<T> rescue(final Function<Throwable, ? extends Future<T>> f) { |
| 730 | if (getInterruptHandler() != null) |
| 731 | return continuation(new Rescue<T>(f) { |
| 732 | @Override |
| 733 | protected final InterruptHandler getInterruptHandler() { |
| 734 | return Promise.this; |
| 735 | } |
| 736 | }); |
| 737 | else |
| 738 | return continuation(new Rescue<T>(f)); |
| 739 | } |
| 740 | |
| 741 | private static class Voided<T> extends Continuation<T, Void> { |
| 742 | @Override |
nothing calls this directly
no test coverage detected