42 lines
1.0 KiB
Java
42 lines
1.0 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
/* renamed from: o.fUi, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13230fUi<T> extends fRY {
|
||
|
|
private fSD<T> b;
|
||
|
|
|
||
|
|
public C13230fUi(fSD<T> fsd) {
|
||
|
|
this.b = fsd;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fRY
|
||
|
|
public final void c(InterfaceC13154fSb interfaceC13154fSb) {
|
||
|
|
this.b.c(new HBt(interfaceC13154fSb));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.fUi$HBt */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
static final class HBt<T> implements InterfaceC13176fSx<T> {
|
||
|
|
private InterfaceC13154fSb c;
|
||
|
|
|
||
|
|
HBt(InterfaceC13154fSb interfaceC13154fSb) {
|
||
|
|
this.c = interfaceC13154fSb;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13176fSx
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
this.c.onError(th);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13176fSx
|
||
|
|
public final void onSubscribe(fSJ fsj) {
|
||
|
|
this.c.onSubscribe(fsj);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13176fSx
|
||
|
|
public final void e(T t) {
|
||
|
|
this.c.onComplete();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|