Skip to content

Commit 58fb566

Browse files
vanniktechakarnokd
authored andcommitted
2.x: Add missing @test annotation on tests (ReactiveX#4597)
* 2.x: Add missing @test annotation on tests * Fix test
1 parent 47b3c6f commit 58fb566

File tree

3 files changed

+10
-0
lines changed

3 files changed

+10
-0
lines changed

src/test/java/io/reactivex/internal/operators/flowable/FlowableDelayTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -787,6 +787,8 @@ public void testErrorRunsBeforeOnNext() {
787787
ts.assertError(TestException.class);
788788
ts.assertNotComplete();
789789
}
790+
791+
@Test
790792
public void testDelaySupplierSimple() {
791793
final PublishProcessor<Integer> ps = PublishProcessor.create();
792794

src/test/java/io/reactivex/internal/operators/flowable/FlowableTakeUntilTest.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -252,6 +252,8 @@ public void testDownstreamUnsubscribes() {
252252
assertFalse("Until still has observers", until.hasSubscribers());
253253
assertFalse("TestSubscriber is unsubscribed", ts.isCancelled());
254254
}
255+
256+
@Test
255257
public void testBackpressure() {
256258
PublishProcessor<Integer> until = PublishProcessor.create();
257259

@@ -267,6 +269,11 @@ public void testBackpressure() {
267269
ts.assertNoErrors();
268270
ts.assertNotComplete();
269271

272+
until.onNext(5);
273+
274+
ts.assertComplete();
275+
ts.assertNoErrors();
276+
270277
assertFalse("Until still has observers", until.hasSubscribers());
271278
assertFalse("TestSubscriber is unsubscribed", ts.isCancelled());
272279
}

src/test/java/io/reactivex/internal/operators/observable/ObservableDelayTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -789,6 +789,7 @@ public void testErrorRunsBeforeOnNext() {
789789
ts.assertNotComplete();
790790
}
791791

792+
@Test
792793
public void testDelaySupplierSimple() {
793794
final PublishSubject<Integer> ps = PublishSubject.create();
794795

0 commit comments

Comments
 (0)