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.15 by jsr166, Sun Nov 6 22:50:32 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);

Diff Legend

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