137 lines
4.0 KiB
Java
137 lines
4.0 KiB
Java
package o;
|
|
|
|
import java.util.concurrent.TimeUnit;
|
|
import o.AbstractC13173fSu;
|
|
|
|
/* renamed from: o.fVE, reason: case insensitive filesystem */
|
|
/* loaded from: classes6.dex */
|
|
public final class C13251fVE<T> extends fUX<T, T> {
|
|
private boolean a;
|
|
private TimeUnit b;
|
|
private long d;
|
|
private AbstractC13173fSu e;
|
|
|
|
public C13251fVE(InterfaceC13169fSq<T> interfaceC13169fSq, long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
|
|
super(interfaceC13169fSq);
|
|
this.d = j;
|
|
this.b = timeUnit;
|
|
this.e = abstractC13173fSu;
|
|
this.a = z;
|
|
}
|
|
|
|
@Override // o.AbstractC13163fSk
|
|
public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
|
this.c.subscribe(new Sts(!this.a ? new C13406fZi(interfaceC13174fSv) : interfaceC13174fSv, this.d, this.b, this.e.c(), this.a));
|
|
}
|
|
|
|
/* renamed from: o.fVE$Sts */
|
|
/* loaded from: classes6.dex */
|
|
static final class Sts<T> implements InterfaceC13174fSv<T>, fSJ {
|
|
private boolean a;
|
|
final InterfaceC13174fSv<? super T> b;
|
|
private TimeUnit c;
|
|
private long d;
|
|
final AbstractC13173fSu.Sts e;
|
|
private fSJ h;
|
|
|
|
Sts(InterfaceC13174fSv<? super T> interfaceC13174fSv, long j, TimeUnit timeUnit, AbstractC13173fSu.Sts sts, boolean z) {
|
|
this.b = interfaceC13174fSv;
|
|
this.d = j;
|
|
this.c = timeUnit;
|
|
this.e = sts;
|
|
this.a = z;
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onSubscribe(fSJ fsj) {
|
|
if (EnumC13192fTf.d(this.h, fsj)) {
|
|
this.h = fsj;
|
|
this.b.onSubscribe(this);
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onNext(T t) {
|
|
this.e.a(new HBt(this, t), this.d, this.c);
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
this.e.a(new RunnableC0113Sts(this, th), this.a ? this.d : 0L, this.c);
|
|
}
|
|
|
|
@Override // o.InterfaceC13174fSv
|
|
public final void onComplete() {
|
|
this.e.a(new RVV(this), this.d, this.c);
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final void dispose() {
|
|
this.h.dispose();
|
|
this.e.dispose();
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final boolean isDisposed() {
|
|
return this.e.isDisposed();
|
|
}
|
|
|
|
/* renamed from: o.fVE$Sts$HBt */
|
|
/* loaded from: classes6.dex */
|
|
final class HBt implements Runnable {
|
|
private Sts b;
|
|
private final T e;
|
|
|
|
HBt(Sts sts, T t) {
|
|
this.b = sts;
|
|
this.e = t;
|
|
}
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
this.b.b.onNext(this.e);
|
|
}
|
|
}
|
|
|
|
/* renamed from: o.fVE$Sts$Sts, reason: collision with other inner class name */
|
|
/* loaded from: classes6.dex */
|
|
final class RunnableC0113Sts implements Runnable {
|
|
private final Throwable b;
|
|
private Sts d;
|
|
|
|
RunnableC0113Sts(Sts sts, Throwable th) {
|
|
this.d = sts;
|
|
this.b = th;
|
|
}
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
try {
|
|
this.d.b.onError(this.b);
|
|
} finally {
|
|
this.d.e.dispose();
|
|
}
|
|
}
|
|
}
|
|
|
|
/* renamed from: o.fVE$Sts$RVV */
|
|
/* loaded from: classes6.dex */
|
|
final class RVV implements Runnable {
|
|
private Sts b;
|
|
|
|
RVV(Sts sts) {
|
|
this.b = sts;
|
|
}
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
try {
|
|
this.b.b.onComplete();
|
|
} finally {
|
|
this.b.e.dispose();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|