(final Transformer<? super T, ? extends R> t)
| 513 | } |
| 514 | |
| 515 | @Override |
| 516 | public <R> Future<R> transform(final Transformer<? super T, ? extends R> t) { |
| 517 | if (getInterruptHandler() != null) |
| 518 | return continuation(new Transform<T, R>(t) { |
| 519 | @Override |
| 520 | protected final InterruptHandler getInterruptHandler() { |
| 521 | return Promise.this; |
| 522 | } |
| 523 | }); |
| 524 | else |
| 525 | return continuation(new Transform<T, R>(t)); |
| 526 | } |
| 527 | |
| 528 | private static class TransformWith<T, R> extends Continuation<T, R> { |
| 529 | private final Transformer<? super T, ? extends Future<R>> t; |
nothing calls this directly
no test coverage detected