Skip to content

Commit da34188

Browse files
chintandoChintan Doshi
and
Chintan Doshi
authored
Convert CompletableOnErrorComplete$onError inner class to static (#7575)
* pass predicate to avoid holding reference * static * fix compile error --------- Co-authored-by: Chintan Doshi <chintan.doshi@snap.com>
1 parent 806ec1c commit da34188

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

src/main/java/io/reactivex/rxjava3/internal/operators/completable/CompletableOnErrorComplete.java

+6-3
Original file line numberDiff line numberDiff line change
@@ -32,15 +32,18 @@ public CompletableOnErrorComplete(CompletableSource source, Predicate<? super Th
3232
@Override
3333
protected void subscribeActual(final CompletableObserver observer) {
3434

35-
source.subscribe(new OnError(observer));
35+
source.subscribe(new OnError(observer, predicate));
3636
}
3737

38-
final class OnError implements CompletableObserver {
38+
static final class OnError implements CompletableObserver {
3939

4040
private final CompletableObserver downstream;
41+
private final Predicate<? super Throwable> predicate;
4142

42-
OnError(CompletableObserver observer) {
43+
OnError(CompletableObserver observer,
44+
Predicate<? super Throwable> predicate) {
4345
this.downstream = observer;
46+
this.predicate = predicate;
4447
}
4548

4649
@Override

0 commit comments

Comments
 (0)