ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/SubmissionPublisherTest.java
(Generate patch)

Comparing jsr166/src/test/tck/SubmissionPublisherTest.java (file contents):
Revision 1.17 by dl, Thu Dec 15 17:34:51 2016 UTC vs.
Revision 1.18 by jsr166, Wed Jan 4 06:09:58 2017 UTC

# Line 146 | Line 146 | public class SubmissionPublisherTest ext
146       * defaultExecutor
147       */
148      public void testConstructor1() {
149 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>();
149 >        SubmissionPublisher<Integer> p = new SubmissionPublisher<>();
150          checkInitialState(p);
151          assertEquals(p.getMaxBufferCapacity(), Flow.defaultBufferSize());
152          Executor e = p.getExecutor(), c = ForkJoinPool.commonPool();
# Line 162 | Line 162 | public class SubmissionPublisherTest ext
162       */
163      public void testConstructor2() {
164          Executor e = Executors.newFixedThreadPool(1);
165 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(e, 8);
165 >        SubmissionPublisher<Integer> p = new SubmissionPublisher<>(e, 8);
166          checkInitialState(p);
167          assertSame(p.getExecutor(), e);
168          assertEquals(8, p.getMaxBufferCapacity());
# Line 444 | Line 444 | public class SubmissionPublisherTest ext
444       */
445      public void testThrowOnNextHandler() {
446          AtomicInteger calls = new AtomicInteger();
447 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>
448 <            (basicExecutor, 8,
449 <             (s, e) -> calls.getAndIncrement());
447 >        SubmissionPublisher<Integer> p = new SubmissionPublisher<>(
448 >            basicExecutor, 8, (s, e) -> calls.getAndIncrement());
449          TestSubscriber s1 = new TestSubscriber();
450          TestSubscriber s2 = new TestSubscriber();
451          p.subscribe(s1);
# Line 627 | Line 626 | public class SubmissionPublisherTest ext
626       * submit eventually issues requested items when buffer capacity is 1
627       */
628      public void testCap1Submit() {
629 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
630 <            basicExecutor, 1);
629 >        SubmissionPublisher<Integer> p
630 >            = new SubmissionPublisher<>(basicExecutor, 1);
631          TestSubscriber s1 = new TestSubscriber();
632          TestSubscriber s2 = new TestSubscriber();
633          p.subscribe(s1);
# Line 706 | Line 705 | public class SubmissionPublisherTest ext
705       * offer reports drops if saturated
706       */
707      public void testDroppedOffer() {
708 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
709 <            basicExecutor, 4);
708 >        SubmissionPublisher<Integer> p
709 >            = new SubmissionPublisher<>(basicExecutor, 4);
710          TestSubscriber s1 = new TestSubscriber();
711          s1.request = false;
712          TestSubscriber s2 = new TestSubscriber();
# Line 735 | Line 734 | public class SubmissionPublisherTest ext
734       */
735      public void testHandledDroppedOffer() {
736          AtomicInteger calls = new AtomicInteger();
737 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
738 <            basicExecutor, 4);
737 >        SubmissionPublisher<Integer> p
738 >            = new SubmissionPublisher<>(basicExecutor, 4);
739          TestSubscriber s1 = new TestSubscriber();
740          s1.request = false;
741          TestSubscriber s2 = new TestSubscriber();
# Line 763 | Line 762 | public class SubmissionPublisherTest ext
762       */
763      public void testRecoveredHandledDroppedOffer() {
764          AtomicInteger calls = new AtomicInteger();
765 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
766 <            basicExecutor, 4);
765 >        SubmissionPublisher<Integer> p
766 >            = new SubmissionPublisher<>(basicExecutor, 4);
767          TestSubscriber s1 = new TestSubscriber();
768          s1.request = false;
769          TestSubscriber s2 = new TestSubscriber();
# Line 844 | Line 843 | public class SubmissionPublisherTest ext
843       * Timed offer reports drops if saturated
844       */
845      public void testDroppedTimedOffer() {
846 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
847 <            basicExecutor, 4);
846 >        SubmissionPublisher<Integer> p
847 >            = new SubmissionPublisher<>(basicExecutor, 4);
848          TestSubscriber s1 = new TestSubscriber();
849          s1.request = false;
850          TestSubscriber s2 = new TestSubscriber();
# Line 876 | Line 875 | public class SubmissionPublisherTest ext
875       */
876      public void testHandledDroppedTimedOffer() {
877          AtomicInteger calls = new AtomicInteger();
878 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
879 <            basicExecutor, 4);
878 >        SubmissionPublisher<Integer> p
879 >            = new SubmissionPublisher<>(basicExecutor, 4);
880          TestSubscriber s1 = new TestSubscriber();
881          s1.request = false;
882          TestSubscriber s2 = new TestSubscriber();
# Line 906 | Line 905 | public class SubmissionPublisherTest ext
905       */
906      public void testRecoveredHandledDroppedTimedOffer() {
907          AtomicInteger calls = new AtomicInteger();
908 <        SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
909 <            basicExecutor, 4);
908 >        SubmissionPublisher<Integer> p
909 >            = new SubmissionPublisher<>(basicExecutor, 4);
910          TestSubscriber s1 = new TestSubscriber();
911          s1.request = false;
912          TestSubscriber s2 = new TestSubscriber();

Diff Legend

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