ViewVC Help

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

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

Comparing jsr166/src/test/tck/SubmissionPublisherTest.java (file contents):
Revision 1.10 by dl, Sat Sep 12 11:25:15 2015 UTC vs.
Revision 1.11 by jsr166, Sat Sep 12 17:11:12 2015 UTC

#	Line 956 | Line 956 | public class SubmissionPublisherTest ext
956		public void testConsume() {
957		AtomicInteger sum = new AtomicInteger();
958		SubmissionPublisher<Integer> p = basicPublisher();
959	<	CompletableFuture<Void> f =
959	>	CompletableFuture<Void> f =
960		p.consume((Integer x) -> { sum.getAndAdd(x.intValue()); });
961		int n = 20;
962		for (int i = 1; i <= n; ++i)
#	Line 974 | Line 974 | public class SubmissionPublisherTest ext
974		try {
975		CompletableFuture<Void> f = p.consume(null);
976		shouldThrow();
977	<	} catch(NullPointerException success) {
978	<	}
977	>	} catch (NullPointerException success) {}
978		}
979
980		/**
#	Line 991 | Line 990 | public class SubmissionPublisherTest ext
990		p.submit(i);
991		assertTrue(count.get() < n);
992		}
993	<
993	>
994		}

Diff Legend

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