Skip to content

Commit d747d52

Browse files
author
Steven Wu
committed
fix several typos
1 parent c41b37d commit d747d52

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
@@ -46,7 +46,7 @@ public void testNoBackpressureSupport() {
4646
@Test(timeout = 500)
4747
public void testWithObserveOn() throws InterruptedException {
4848
TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
49-
Observable.range(0, RxRingBuffer.SIZE * 10).onBackpressureDrop().onBackpressureDrop().observeOn(Schedulers.io()).subscribe(ts);
49+
Observable.range(0, RxRingBuffer.SIZE * 10).onBackpressureDrop().observeOn(Schedulers.io()).subscribe(ts);
5050
ts.awaitTerminalEvent();
5151
}
5252

0 commit comments

Comments
 (0)