4835 |
|
final AtomicInteger ran = new AtomicInteger(0); |
4836 |
|
final CompletableFuture<Item> f = new CompletableFuture<>(); |
4837 |
|
final DelegatedCompletionStage<Item> d = |
4838 |
< |
new DelegatedCompletionStage<Item>(f); |
4838 |
> |
new DelegatedCompletionStage<>(f); |
4839 |
|
if (!createIncomplete) assertTrue(f.complete(v1)); |
4840 |
|
final CompletionStage<Item> g = d.exceptionallyAsync |
4841 |
|
((Throwable t) -> { |
4861 |
|
final CFException ex = new CFException(); |
4862 |
|
final CompletableFuture<Item> f = new CompletableFuture<>(); |
4863 |
|
final DelegatedCompletionStage<Item> d = |
4864 |
< |
new DelegatedCompletionStage<Item>(f); |
4864 |
> |
new DelegatedCompletionStage<>(f); |
4865 |
|
if (!createIncomplete) f.completeExceptionally(ex); |
4866 |
|
final CompletionStage<Item> g = d.exceptionallyAsync |
4867 |
|
((Throwable t) -> { |
4889 |
|
final CFException ex2 = new CFException(); |
4890 |
|
final CompletableFuture<Item> f = new CompletableFuture<>(); |
4891 |
|
final DelegatedCompletionStage<Item> d = |
4892 |
< |
new DelegatedCompletionStage<Item>(f); |
4892 |
> |
new DelegatedCompletionStage<>(f); |
4893 |
|
if (!createIncomplete) f.completeExceptionally(ex1); |
4894 |
|
final CompletionStage<Item> g = d.exceptionallyAsync |
4895 |
|
((Throwable t) -> { |
4917 |
|
final ExceptionalCompletableFutureFunction r = |
4918 |
|
new ExceptionalCompletableFutureFunction(ExecutionMode.SYNC); |
4919 |
|
final DelegatedCompletionStage<Item> d = |
4920 |
< |
new DelegatedCompletionStage<Item>(f); |
4920 |
> |
new DelegatedCompletionStage<>(f); |
4921 |
|
if (!createIncomplete) assertTrue(f.complete(v1)); |
4922 |
|
final CompletionStage<Item> g = d.exceptionallyCompose(r); |
4923 |
|
if (createIncomplete) assertTrue(f.complete(v1)); |
4939 |
|
new ExceptionalCompletableFutureFunction(ExecutionMode.SYNC); |
4940 |
|
final CompletableFuture<Item> f = new CompletableFuture<>(); |
4941 |
|
final DelegatedCompletionStage<Item> d = |
4942 |
< |
new DelegatedCompletionStage<Item>(f); |
4942 |
> |
new DelegatedCompletionStage<>(f); |
4943 |
|
if (!createIncomplete) f.completeExceptionally(ex); |
4944 |
|
final CompletionStage<Item> g = d.exceptionallyCompose(r); |
4945 |
|
if (createIncomplete) f.completeExceptionally(ex); |
4961 |
|
final FailingExceptionalCompletableFutureFunction r |
4962 |
|
= new FailingExceptionalCompletableFutureFunction(ExecutionMode.SYNC); |
4963 |
|
final DelegatedCompletionStage<Item> d = |
4964 |
< |
new DelegatedCompletionStage<Item>(f); |
4964 |
> |
new DelegatedCompletionStage<>(f); |
4965 |
|
if (!createIncomplete) f.completeExceptionally(ex); |
4966 |
|
final CompletionStage<Item> g = d.exceptionallyCompose(r); |
4967 |
|
if (createIncomplete) f.completeExceptionally(ex); |
4983 |
|
final ExceptionalCompletableFutureFunction r = |
4984 |
|
new ExceptionalCompletableFutureFunction(ExecutionMode.ASYNC); |
4985 |
|
final DelegatedCompletionStage<Item> d = |
4986 |
< |
new DelegatedCompletionStage<Item>(f); |
4986 |
> |
new DelegatedCompletionStage<>(f); |
4987 |
|
if (!createIncomplete) assertTrue(f.complete(v1)); |
4988 |
|
final CompletionStage<Item> g = d.exceptionallyComposeAsync(r); |
4989 |
|
if (createIncomplete) assertTrue(f.complete(v1)); |
5005 |
|
new ExceptionalCompletableFutureFunction(ExecutionMode.ASYNC); |
5006 |
|
final CompletableFuture<Item> f = new CompletableFuture<>(); |
5007 |
|
final DelegatedCompletionStage<Item> d = |
5008 |
< |
new DelegatedCompletionStage<Item>(f); |
5008 |
> |
new DelegatedCompletionStage<>(f); |
5009 |
|
if (!createIncomplete) f.completeExceptionally(ex); |
5010 |
|
final CompletionStage<Item> g = d.exceptionallyComposeAsync(r); |
5011 |
|
if (createIncomplete) f.completeExceptionally(ex); |
5027 |
|
final FailingExceptionalCompletableFutureFunction r |
5028 |
|
= new FailingExceptionalCompletableFutureFunction(ExecutionMode.ASYNC); |
5029 |
|
final DelegatedCompletionStage<Item> d = |
5030 |
< |
new DelegatedCompletionStage<Item>(f); |
5030 |
> |
new DelegatedCompletionStage<>(f); |
5031 |
|
if (!createIncomplete) f.completeExceptionally(ex); |
5032 |
|
final CompletionStage<Item> g = d.exceptionallyComposeAsync(r); |
5033 |
|
if (createIncomplete) f.completeExceptionally(ex); |
5049 |
|
final ExceptionalCompletableFutureFunction r = |
5050 |
|
new ExceptionalCompletableFutureFunction(ExecutionMode.EXECUTOR); |
5051 |
|
final DelegatedCompletionStage<Item> d = |
5052 |
< |
new DelegatedCompletionStage<Item>(f); |
5052 |
> |
new DelegatedCompletionStage<>(f); |
5053 |
|
if (!createIncomplete) assertTrue(f.complete(v1)); |
5054 |
|
final CompletionStage<Item> g = d.exceptionallyComposeAsync(r, new ThreadExecutor()); |
5055 |
|
if (createIncomplete) assertTrue(f.complete(v1)); |
5071 |
|
new ExceptionalCompletableFutureFunction(ExecutionMode.EXECUTOR); |
5072 |
|
final CompletableFuture<Item> f = new CompletableFuture<>(); |
5073 |
|
final DelegatedCompletionStage<Item> d = |
5074 |
< |
new DelegatedCompletionStage<Item>(f); |
5074 |
> |
new DelegatedCompletionStage<>(f); |
5075 |
|
if (!createIncomplete) f.completeExceptionally(ex); |
5076 |
|
final CompletionStage<Item> g = d.exceptionallyComposeAsync(r, new ThreadExecutor()); |
5077 |
|
if (createIncomplete) f.completeExceptionally(ex); |
5093 |
|
final FailingExceptionalCompletableFutureFunction r |
5094 |
|
= new FailingExceptionalCompletableFutureFunction(ExecutionMode.EXECUTOR); |
5095 |
|
final DelegatedCompletionStage<Item> d = |
5096 |
< |
new DelegatedCompletionStage<Item>(f); |
5096 |
> |
new DelegatedCompletionStage<>(f); |
5097 |
|
if (!createIncomplete) f.completeExceptionally(ex); |
5098 |
|
final CompletionStage<Item> g = d.exceptionallyComposeAsync(r, new ThreadExecutor()); |
5099 |
|
if (createIncomplete) f.completeExceptionally(ex); |