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.16 by dl, Sun Dec 11 22:11:45 2016 UTC

#	Line 375 | Line 375 | public class SubmissionPublisherTest ext
375
376		/**
377		* Closing a publisher exceptionally causes onError to subscribers
378	+	* after they are subscribed
379		*/
380		public void testCloseExceptionallyError() {
381		SubmissionPublisher<Integer> p = basicPublisher();
#	Line 385 | Line 386 | public class SubmissionPublisherTest ext
386		p.submit(1);
387		p.closeExceptionally(new SPException());
388		assertTrue(p.isClosed());
389	+	s1.awaitSubscribe();
390		s1.awaitError();
391		assertTrue(s1.nexts <= 1);
392		assertEquals(1, s1.errors);
393	+	s1.awaitSubscribe();
394		s2.awaitError();
395		assertTrue(s2.nexts <= 1);
396		assertEquals(1, s2.errors);
#	Line 936 | Line 939 | public class SubmissionPublisherTest ext
939		AtomicInteger sum = new AtomicInteger();
940		SubmissionPublisher<Integer> p = basicPublisher();
941		CompletableFuture<Void> f =
942	<	p.consume((Integer x) -> { sum.getAndAdd(x.intValue()); });
942	>	p.consume((Integer x) -> sum.getAndAdd(x.intValue()));
943		int n = 20;
944		for (int i = 1; i <= n; ++i)
945		p.submit(i);

Diff Legend

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