(final Future<U> other,
final BiFunction<? super T, ? super U, ? extends Future<R>> f)
| 595 | } |
| 596 | |
| 597 | @Override |
| 598 | public <U, R> Future<R> biFlatMap(final Future<U> other, |
| 599 | final BiFunction<? super T, ? super U, ? extends Future<R>> f) { |
| 600 | if (getInterruptHandler() != null) |
| 601 | return continuation(new BiFlatMap<T, U, R>(other, f) { |
| 602 | @Override |
| 603 | protected final InterruptHandler getInterruptHandler() { |
| 604 | return InterruptHandler.apply(Promise.this, other); |
| 605 | } |
| 606 | }); |
| 607 | else |
| 608 | return continuation(new BiFlatMap<T, U, R>(other, f)); |
| 609 | } |
| 610 | |
| 611 | private static class Ensure<T> extends Continuation<T, T> { |
| 612 | private final Runnable f; |
nothing calls this directly
no test coverage detected