ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/CompletableFutureTest.java

Comparing jsr166/src/test/tck/CompletableFutureTest.java (file contents):
Revision 1.182 by jsr166, Tue Jan 3 03:18:02 2017 UTC vs.
Revision 1.183 by jsr166, Wed Jan 4 06:09:58 2017 UTC

#	Line 3532 | Line 3532 | public class CompletableFutureTest exten
3532		*/
3533		public void testCompletedStage() {
3534		AtomicInteger x = new AtomicInteger(0);
3535	<	AtomicReference<Throwable> r = new AtomicReference<Throwable>();
3535	>	AtomicReference<Throwable> r = new AtomicReference<>();
3536		CompletionStage<Integer> f = CompletableFuture.completedStage(1);
3537		f.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);});
3538		assertEquals(x.get(), 1);
#	Line 3634 | Line 3634 | public class CompletableFutureTest exten
3634		CompletableFuture<Integer> f = new CompletableFuture<>();
3635		CompletionStage<Integer> g = f.minimalCompletionStage();
3636		AtomicInteger x = new AtomicInteger(0);
3637	<	AtomicReference<Throwable> r = new AtomicReference<Throwable>();
3637	>	AtomicReference<Throwable> r = new AtomicReference<>();
3638		checkIncomplete(f);
3639		g.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);});
3640		f.complete(1);
#	Line 3651 | Line 3651 | public class CompletableFutureTest exten
3651		CompletableFuture<Integer> f = new CompletableFuture<>();
3652		CompletionStage<Integer> g = f.minimalCompletionStage();
3653		AtomicInteger x = new AtomicInteger(0);
3654	<	AtomicReference<Throwable> r = new AtomicReference<Throwable>();
3654	>	AtomicReference<Throwable> r = new AtomicReference<>();
3655		g.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);});
3656		checkIncomplete(f);
3657		CFException ex = new CFException();
#	Line 3669 | Line 3669 | public class CompletableFutureTest exten
3669		CFException ex = new CFException();
3670		CompletionStage<Integer> f = CompletableFuture.failedStage(ex);
3671		AtomicInteger x = new AtomicInteger(0);
3672	<	AtomicReference<Throwable> r = new AtomicReference<Throwable>();
3672	>	AtomicReference<Throwable> r = new AtomicReference<>();
3673		f.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);});
3674		assertEquals(x.get(), 0);
3675		assertEquals(r.get(), ex);

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines