Skip to content

Commit ca57030

Browse files
committed
revert change to onStart request
1 parent 96b807c commit ca57030

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

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

111111
@Override
112112
public void onStart() {
113-
// no need for more than 1 at a time
114-
request(1);
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);
115116
}
116117

117118
private void requestFromChild(long n) {

0 commit comments

Comments
 (0)