File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
src/test/java/rx/internal/operators Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -253,9 +253,11 @@ public void testSecondaryRequestsPropagatedToChildren() throws InterruptedExcept
253
253
//this stream emits second
254
254
Observable <Integer > o2 = Observable .from (Arrays .asList (4 , 5 , 6 ))
255
255
.delay (200 , TimeUnit .MILLISECONDS ).subscribeOn (Schedulers .computation ());
256
- TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
257
- //before subscription request 1
258
- ts .requestMore (1 );
256
+ TestSubscriber <Integer > ts = new TestSubscriber <Integer >() {
257
+ @ Override
258
+ public void onStart () {
259
+ request (1 );
260
+ }};
259
261
Observable .amb (o1 , o2 ).subscribe (ts );
260
262
// before first emission request 20 more
261
263
// this request should suffice to emit all
You can’t perform that action at this time.
0 commit comments