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.14 by jsr166, Wed Aug 24 22:22:39 2016 UTC vs.
Revision 1.15 by jsr166, Sun Nov 6 22:50:32 2016 UTC

#	Line 936 | Line 936 | public class SubmissionPublisherTest ext
936		AtomicInteger sum = new AtomicInteger();
937		SubmissionPublisher<Integer> p = basicPublisher();
938		CompletableFuture<Void> f =
939	<	p.consume((Integer x) -> { sum.getAndAdd(x.intValue()); });
939	>	p.consume((Integer x) -> sum.getAndAdd(x.intValue()));
940		int n = 20;
941		for (int i = 1; i <= n; ++i)
942		p.submit(i);

Diff Legend

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