979 |
|
} catch (Throwable ex) { |
980 |
|
d.result = encodeThrowable(ex); |
981 |
|
} |
982 |
< |
} |
982 |
> |
} |
983 |
|
return d; |
984 |
|
} |
985 |
|
|
993 |
|
} |
994 |
|
final CompletableFuture<T> tryFire(int mode) { |
995 |
|
CompletableFuture<T> d; CompletableFuture<T> a; |
996 |
< |
Function<Throwable, ? extends CompletionStage<T>> f; |
996 |
> |
Function<Throwable, ? extends CompletionStage<T>> f; |
997 |
|
Object r; Throwable x; |
998 |
|
if ((d = dep) == null || (f = fn) == null |
999 |
|
|| (a = src) == null || (r = a.result) == null) |
1056 |
|
return d; |
1057 |
|
} |
1058 |
|
|
1059 |
< |
|
1059 |
> |
|
1060 |
|
@SuppressWarnings("serial") |
1061 |
|
static final class UniRelay<U, T extends U> extends UniCompletion<T,U> { |
1062 |
|
UniRelay(CompletableFuture<U> dep, CompletableFuture<T> src) { |
2353 |
|
return uniExceptionallyStage(screenExecutor(executor), fn); |
2354 |
|
} |
2355 |
|
|
2356 |
< |
public CompletableFuture<T> exceptionallyCompose( |
2356 |
> |
public CompletableFuture<T> exceptionallyCompose( |
2357 |
|
Function<Throwable, ? extends CompletionStage<T>> fn) { |
2358 |
|
return uniComposeExceptionallyStage(null, fn); |
2359 |
|
} |
2368 |
|
Executor executor) { |
2369 |
|
return uniComposeExceptionallyStage(screenExecutor(executor), fn); |
2370 |
|
} |
2371 |
< |
|
2371 |
> |
|
2372 |
|
/* ------------- Arbitrary-arity constructions -------------- */ |
2373 |
|
|
2374 |
|
/** |