75 lines
2.1 KiB
Java
75 lines
2.1 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public abstract class wRi {
|
||
|
|
private yRw a;
|
||
|
|
public yRw f;
|
||
|
|
public C13196fTj h = new C13196fTj();
|
||
|
|
public AbstractC13163fSk i;
|
||
|
|
|
||
|
|
/* loaded from: classes3.dex */
|
||
|
|
public static class LWm<T> extends AbstractC13403fZf<T> {
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public void onComplete() {
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public void onError(Throwable th) {
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public void onNext(T t) {
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public wRi(yRw yrw, yRw yrw2) {
|
||
|
|
this.f = yrw;
|
||
|
|
this.a = yrw2;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void a(LWm lWm) {
|
||
|
|
d(this.i, lWm);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
public final <T> void e(AbstractC13163fSk<T> abstractC13163fSk, fSQ<T> fsq) {
|
||
|
|
d(abstractC13163fSk.subscribeOn(this.f.d).observeOn(this.a.d).subscribe(fsq));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
public final <T> void d(AbstractC13163fSk<T> abstractC13163fSk, fSQ<T> fsq, fSQ<Throwable> fsq2) {
|
||
|
|
d(abstractC13163fSk.subscribeOn(this.f.d).observeOn(this.a.d).subscribe(fsq, fsq2));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
public final void d(fSJ fsj) {
|
||
|
|
if (this.h.isDisposed()) {
|
||
|
|
this.h = new C13196fTj();
|
||
|
|
}
|
||
|
|
if (fsj != null) {
|
||
|
|
this.h.e(fsj);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public <T> void d(AbstractC13163fSk<T> abstractC13163fSk, LWm<T> lWm) {
|
||
|
|
abstractC13163fSk.subscribeOn(this.f.d).observeOn(this.a.d).doOnSubscribe(new fSQ(this) { // from class: o.Ubc
|
||
|
|
private wRi a;
|
||
|
|
|
||
|
|
@Override // o.fSQ
|
||
|
|
public final void c(Object obj) {
|
||
|
|
this.a.d((fSJ) obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.a = this;
|
||
|
|
}
|
||
|
|
}).safeSubscribe(lWm);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: protected */
|
||
|
|
public final AbstractC13163fSk e(AbstractC13163fSk abstractC13163fSk) {
|
||
|
|
this.i = abstractC13163fSk;
|
||
|
|
return abstractC13163fSk;
|
||
|
|
}
|
||
|
|
}
|