| # | Line 939 | Line 939 | public class CompletableFuture<T> implem | |
|---|---|---|
| 939 | } | |
| 940 | try { | |
| 941 | @SuppressWarnings("unchecked") T t = (T) r; | |
| 942 | < | return f.apply(t).toCompletableFuture(); |
| 942 | > | return new CompletableFuture<V>( |
| 943 | > | encodeRelay(f.apply(t).toCompletableFuture().result)); |
| 944 | } catch (Throwable ex) { | |
| 945 | return new CompletableFuture<V>(encodeThrowable(ex)); | |
| 946 | } | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |