package o; /* renamed from: o.fXj, reason: case insensitive filesystem */ /* loaded from: classes6.dex */ public final class C13336fXj extends fUX { private long a; public C13336fXj(InterfaceC13169fSq interfaceC13169fSq, long j) { super(interfaceC13169fSq); this.a = j; } @Override // o.AbstractC13163fSk public final void subscribeActual(InterfaceC13174fSv interfaceC13174fSv) { this.c.subscribe(new Sts(interfaceC13174fSv, this.a)); } /* renamed from: o.fXj$Sts */ /* loaded from: classes6.dex */ static final class Sts implements InterfaceC13174fSv, fSJ { private long b; private InterfaceC13174fSv d; private fSJ e; Sts(InterfaceC13174fSv interfaceC13174fSv, long j) { this.d = interfaceC13174fSv; this.b = j; } @Override // o.InterfaceC13174fSv public final void onSubscribe(fSJ fsj) { if (EnumC13192fTf.d(this.e, fsj)) { this.e = fsj; this.d.onSubscribe(this); } } @Override // o.InterfaceC13174fSv public final void onNext(T t) { long j = this.b; if (j != 0) { this.b = j - 1; } else { this.d.onNext(t); } } @Override // o.InterfaceC13174fSv public final void onError(Throwable th) { this.d.onError(th); } @Override // o.InterfaceC13174fSv public final void onComplete() { this.d.onComplete(); } @Override // o.fSJ public final void dispose() { this.e.dispose(); } @Override // o.fSJ public final boolean isDisposed() { return this.e.isDisposed(); } } }