File tree 1 file changed +3
-3
lines changed
tck/src/main/java/org/reactivestreams/tck
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -549,7 +549,7 @@ public void run(Publisher<T> pub) throws Throwable {
549
549
});
550
550
}
551
551
552
- // Verifies rule: https://github.com/reactive-streams/reactive-streams#1.12
552
+ // Verifies rule: https://github.com/reactive-streams/reactive-streams#1.11
553
553
@ Override @ Test
554
554
public void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne () throws Throwable {
555
555
optionalActivePublisherTest (5 , true , new PublisherTestRun <T >() { // This test is skipped if the publisher is unbounded (never sends onComplete)
@@ -600,7 +600,7 @@ public void run(Publisher<T> pub) throws InterruptedException {
600
600
});
601
601
}
602
602
603
- // Verifies rule: https://github.com/reactive-streams/reactive-streams#1.12
603
+ // Verifies rule: https://github.com/reactive-streams/reactive-streams#1.11
604
604
@ Override @ Test
605
605
public void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront () throws Throwable {
606
606
optionalActivePublisherTest (3 , false , new PublisherTestRun <T >() { // This test is skipped if the publisher cannot produce enough elements
@@ -633,7 +633,7 @@ public void run(Publisher<T> pub) throws Throwable {
633
633
});
634
634
}
635
635
636
- // Verifies rule: https://github.com/reactive-streams/reactive-streams#1.12
636
+ // Verifies rule: https://github.com/reactive-streams/reactive-streams#1.11
637
637
@ Override @ Test
638
638
public void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected () throws Throwable {
639
639
optionalActivePublisherTest (3 , true , new PublisherTestRun <T >() { // This test is skipped if the publisher is unbounded (never sends onComplete)
You can’t perform that action at this time.
0 commit comments