275 |
|
return t; |
276 |
|
} |
277 |
|
|
278 |
< |
/* ------------- Async task preliminaries -------------- */ |
278 |
> |
/* ------------- Async task preliminaries -------------- */ |
279 |
|
|
280 |
|
/** |
281 |
|
* A marker interface identifying asynchronous tasks produced by |
503 |
|
private <U> CompletableFuture<U> uniApplyStage( |
504 |
|
Executor e, Function<? super T,? extends U> f) { |
505 |
|
if (f == null) throw new NullPointerException(); |
506 |
< |
CompletableFuture<U> d = new CompletableFuture<U>(); |
506 |
> |
CompletableFuture<U> d = new CompletableFuture<U>(); |
507 |
|
if (e != null || !d.uniApply(this, f, null)) { |
508 |
|
UniApply<T,U> c = new UniApply<T,U>(e, d, this, f); |
509 |
|
push(c); |