| 713 | } |
| 714 | |
| 715 | private static class Rescue<T> extends Continuation<T, T> { |
| 716 | private final Function<Throwable, ? extends Future<T>> f; |
| 717 | |
| 718 | public Rescue(final Function<Throwable, ? extends Future<T>> f) { |
| 719 | this.f = f; |
| 720 | } |
| 721 | |
| 722 | @Override |
| 723 | final Future<T> apply(final Future<T> result) { |
| 724 | return result.rescue(f); |
| 725 | } |
| 726 | } |
| 727 | |
| 728 | @Override |
| 729 | public final Future<T> rescue(final Function<Throwable, ? extends Future<T>> f) { |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…