File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed
src/main/java/io/reactivex/internal/operators/parallel Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -199,6 +199,7 @@ public void onComplete() {
199
199
drain ();
200
200
}
201
201
202
+ @ Override
202
203
void drain () {
203
204
if (getAndIncrement () != 0 ) {
204
205
return ;
@@ -323,6 +324,7 @@ static final class JoinSubscriptionDelayError<T> extends JoinSubscriptionBase<T>
323
324
super (actual , n , prefetch );
324
325
}
325
326
327
+ @ Override
326
328
void onNext (JoinInnerSubscriber <T > inner , T value ) {
327
329
if (get () == 0 && compareAndSet (0 , 1 )) {
328
330
if (requested .get () != 0 ) {
@@ -363,17 +365,20 @@ void onNext(JoinInnerSubscriber<T> inner, T value) {
363
365
drainLoop ();
364
366
}
365
367
368
+ @ Override
366
369
void onError (Throwable e ) {
367
370
errors .addThrowable (e );
368
371
done .decrementAndGet ();
369
372
drain ();
370
373
}
371
374
375
+ @ Override
372
376
void onComplete () {
373
377
done .decrementAndGet ();
374
378
drain ();
375
379
}
376
380
381
+ @ Override
377
382
void drain () {
378
383
if (getAndIncrement () != 0 ) {
379
384
return ;
You can’t perform that action at this time.
0 commit comments