90 lines
2.1 KiB
Java
90 lines
2.1 KiB
Java
package o;
|
|
|
|
/* loaded from: classes6.dex */
|
|
public abstract class fTA<T, R> implements InterfaceC13174fSv<T>, InterfaceC13412fZo<R> {
|
|
private fSJ a;
|
|
public int b;
|
|
public boolean c;
|
|
public final InterfaceC13174fSv<? super R> d;
|
|
public InterfaceC13412fZo<T> e;
|
|
|
|
public fTA(InterfaceC13174fSv<? super R> interfaceC13174fSv) {
|
|
this.d = interfaceC13174fSv;
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onSubscribe(fSJ fsj) {
|
|
if (EnumC13192fTf.d(this.a, fsj)) {
|
|
this.a = fsj;
|
|
if (fsj instanceof InterfaceC13412fZo) {
|
|
this.e = (InterfaceC13412fZo) fsj;
|
|
}
|
|
this.d.onSubscribe(this);
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public void onError(Throwable th) {
|
|
if (this.c) {
|
|
C13418fZu.c(th);
|
|
} else {
|
|
this.c = true;
|
|
this.d.onError(th);
|
|
}
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: protected */
|
|
public final void b(Throwable th) {
|
|
C13147fSI.c(th);
|
|
this.a.dispose();
|
|
onError(th);
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public void onComplete() {
|
|
if (this.c) {
|
|
return;
|
|
}
|
|
this.c = true;
|
|
this.d.onComplete();
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: protected */
|
|
public final int e(int i) {
|
|
InterfaceC13412fZo<T> interfaceC13412fZo = this.e;
|
|
if (interfaceC13412fZo == null || (i & 4) != 0) {
|
|
return 0;
|
|
}
|
|
int b = interfaceC13412fZo.b(i);
|
|
if (b != 0) {
|
|
this.b = b;
|
|
}
|
|
return b;
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public void dispose() {
|
|
this.a.dispose();
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public boolean isDisposed() {
|
|
return this.a.isDisposed();
|
|
}
|
|
|
|
@Override // o.InterfaceC13414fZq
|
|
public final boolean c() {
|
|
return this.e.c();
|
|
}
|
|
|
|
@Override // o.InterfaceC13414fZq
|
|
public void e() {
|
|
this.e.e();
|
|
}
|
|
|
|
@Override // o.InterfaceC13414fZq
|
|
public final boolean b(R r) {
|
|
throw new UnsupportedOperationException("Should not be called!");
|
|
}
|
|
}
|