63 lines
1.6 KiB
Java
63 lines
1.6 KiB
Java
package o;
|
|
|
|
/* renamed from: o.fWp, reason: case insensitive filesystem */
|
|
/* loaded from: classes.dex */
|
|
public final class C13307fWp<T> extends fRY implements InterfaceC13204fTr<T> {
|
|
private InterfaceC13169fSq<T> e;
|
|
|
|
public C13307fWp(InterfaceC13169fSq<T> interfaceC13169fSq) {
|
|
this.e = interfaceC13169fSq;
|
|
}
|
|
|
|
@Override // o.fRY
|
|
public final void c(InterfaceC13154fSb interfaceC13154fSb) {
|
|
this.e.subscribe(new LWm(interfaceC13154fSb));
|
|
}
|
|
|
|
@Override // o.InterfaceC13204fTr
|
|
public final AbstractC13163fSk<T> b() {
|
|
return new C13305fWn(this.e);
|
|
}
|
|
|
|
/* renamed from: o.fWp$LWm */
|
|
/* loaded from: classes6.dex */
|
|
static final class LWm<T> implements InterfaceC13174fSv<T>, fSJ {
|
|
private fSJ a;
|
|
private InterfaceC13154fSb b;
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onNext(T t) {
|
|
}
|
|
|
|
LWm(InterfaceC13154fSb interfaceC13154fSb) {
|
|
this.b = interfaceC13154fSb;
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onSubscribe(fSJ fsj) {
|
|
this.a = fsj;
|
|
this.b.onSubscribe(this);
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
this.b.onError(th);
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onComplete() {
|
|
this.b.onComplete();
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final void dispose() {
|
|
this.a.dispose();
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final boolean isDisposed() {
|
|
return this.a.isDisposed();
|
|
}
|
|
}
|
|
}
|