Skip to content

Commit 15d030b

Browse files
committed
Merge pull request ReactiveX#2777 from stevenzwu/typo
fix several typos
2 parents 4081e3f + d747d52 commit 15d030b

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/test/java/rx/internal/operators/OperatorOnBackpressureBufferTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public void testFixBackpressureBufferNegativeCapacity() throws InterruptedExcept
9393

9494
@Test(expected = IllegalArgumentException.class)
9595
public void testFixBackpressureBufferZeroCapacity() throws InterruptedException {
96-
Observable.empty().onBackpressureBuffer(-1);
96+
Observable.empty().onBackpressureBuffer(0);
9797
}
9898

9999
@Test

src/test/java/rx/internal/operators/OperatorOnBackpressureDropTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public void testNoBackpressureSupport() {
4747
@Test(timeout = 500)
4848
public void testWithObserveOn() throws InterruptedException {
4949
TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
50-
Observable.range(0, RxRingBuffer.SIZE * 10).onBackpressureDrop().onBackpressureDrop().observeOn(Schedulers.io()).subscribe(ts);
50+
Observable.range(0, RxRingBuffer.SIZE * 10).onBackpressureDrop().observeOn(Schedulers.io()).subscribe(ts);
5151
ts.awaitTerminalEvent();
5252
}
5353

0 commit comments

Comments
 (0)