package o; import java.util.concurrent.atomic.AtomicReference; /* renamed from: o.fUf, reason: case insensitive filesystem */ /* loaded from: classes6.dex */ public final class C13227fUf extends fRY { private fRZ c; private fRZ d; public C13227fUf(fRZ frz, fRZ frz2) { this.c = frz; this.d = frz2; } @Override // o.fRY public final void c(InterfaceC13154fSb interfaceC13154fSb) { this.c.e(new Sts(interfaceC13154fSb, this.d)); } /* renamed from: o.fUf$Sts */ /* loaded from: classes6.dex */ static final class Sts extends AtomicReference implements InterfaceC13154fSb, fSJ { private fRZ b; private InterfaceC13154fSb d; Sts(InterfaceC13154fSb interfaceC13154fSb, fRZ frz) { this.d = interfaceC13154fSb; this.b = frz; } @Override // o.InterfaceC13154fSb public final void onSubscribe(fSJ fsj) { if (EnumC13192fTf.a(this, fsj)) { this.d.onSubscribe(this); } } @Override // o.InterfaceC13154fSb public final void onError(Throwable th) { this.d.onError(th); } @Override // o.InterfaceC13154fSb public final void onComplete() { this.b.e(new RVV(this, this.d)); } @Override // o.fSJ public final void dispose() { EnumC13192fTf.e(this); } @Override // o.fSJ public final boolean isDisposed() { return EnumC13192fTf.c(get()); } } /* renamed from: o.fUf$RVV */ /* loaded from: classes6.dex */ static final class RVV implements InterfaceC13154fSb { private AtomicReference c; private InterfaceC13154fSb d; RVV(AtomicReference atomicReference, InterfaceC13154fSb interfaceC13154fSb) { this.c = atomicReference; this.d = interfaceC13154fSb; } @Override // o.InterfaceC13154fSb public final void onSubscribe(fSJ fsj) { EnumC13192fTf.c(this.c, fsj); } @Override // o.InterfaceC13154fSb public final void onComplete() { this.d.onComplete(); } @Override // o.InterfaceC13154fSb public final void onError(Throwable th) { this.d.onError(th); } } }