Skip to content

Commit 96b807c

Browse files
committed
remove unused imports and only request 1 inner observable in onStart
1 parent 775248c commit 96b807c

File tree

2 files changed

+2
-5
lines changed

2 files changed

+2
-5
lines changed

src/main/java/rx/internal/operators/OperatorConcat.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -110,9 +110,8 @@ public void call() {
110110

111111
@Override
112112
public void onStart() {
113-
// no need for more than 1 at a time since we concat 1 at a time, so we'll request 2 to start ...
114-
// 1 to be subscribed to, 1 in the queue, then we'll keep requesting 1 at a time after that
115-
request(2);
113+
// no need for more than 1 at a time
114+
request(1);
116115
}
117116

118117
private void requestFromChild(long n) {

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,7 @@
3636
import org.mockito.InOrder;
3737

3838
import rx.Observable.OnSubscribe;
39-
import rx.Scheduler.Worker;
4039
import rx.*;
41-
import rx.functions.Action0;
4240
import rx.functions.Func1;
4341
import rx.internal.util.RxRingBuffer;
4442
import rx.observers.TestSubscriber;

0 commit comments

Comments
 (0)