55 lines
2.2 KiB
Java
55 lines
2.2 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.Objects;
|
||
|
|
import java.util.concurrent.TimeUnit;
|
||
|
|
import o.C13246fUy;
|
||
|
|
|
||
|
|
/* renamed from: o.fSc, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public abstract class AbstractC13155fSc<T> implements InterfaceC15340gnp<T> {
|
||
|
|
private static int c = Math.max(1, Integer.getInteger("rx3.buffer-size", 128).intValue());
|
||
|
|
|
||
|
|
protected abstract void c(InterfaceC15338gnn<? super T> interfaceC15338gnn);
|
||
|
|
|
||
|
|
public static AbstractC13155fSc<Long> c(TimeUnit timeUnit) {
|
||
|
|
AbstractC13173fSu e = C13417fZt.e();
|
||
|
|
Objects.requireNonNull(timeUnit, "unit is null");
|
||
|
|
Objects.requireNonNull(e, "scheduler is null");
|
||
|
|
return new fUA(Math.max(0L, 5000L), Math.max(0L, 5000L), timeUnit, e);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final fSJ a(fSQ<? super T> fsq, fSQ<? super Throwable> fsq2, fSP fsp) {
|
||
|
|
Objects.requireNonNull(fsq, "onNext is null");
|
||
|
|
Objects.requireNonNull(fsq2, "onError is null");
|
||
|
|
Objects.requireNonNull(fsp, "onComplete is null");
|
||
|
|
fYG fyg = new fYG(fsq, fsq2, fsp, C13246fUy.Sts.INSTANCE);
|
||
|
|
a((InterfaceC13158fSf) fyg);
|
||
|
|
return fyg;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC15340gnp
|
||
|
|
public final void a(InterfaceC15338gnn<? super T> interfaceC15338gnn) {
|
||
|
|
a((InterfaceC13158fSf) interfaceC15338gnn);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void a(InterfaceC13158fSf<? super T> interfaceC13158fSf) {
|
||
|
|
Objects.requireNonNull(interfaceC13158fSf, "subscriber is null");
|
||
|
|
try {
|
||
|
|
Objects.requireNonNull(interfaceC13158fSf, "The RxJavaPlugins.onSubscribe hook returned a null FlowableSubscriber. Please check the handler provided to RxJavaPlugins.setOnFlowableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
|
||
|
|
c(interfaceC13158fSf);
|
||
|
|
} catch (NullPointerException e) {
|
||
|
|
throw e;
|
||
|
|
} catch (Throwable th) {
|
||
|
|
C13147fSI.c(th);
|
||
|
|
C13418fZu.c(th);
|
||
|
|
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
|
||
|
|
nullPointerException.initCause(th);
|
||
|
|
throw nullPointerException;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static int a() {
|
||
|
|
return c;
|
||
|
|
}
|
||
|
|
}
|