436 lines
17 KiB
Java
436 lines
17 KiB
Java
package rx;
|
|
|
|
import j0.k.a;
|
|
import j0.k.d;
|
|
import j0.k.e;
|
|
import j0.k.g;
|
|
import j0.k.h;
|
|
import j0.k.i;
|
|
import j0.k.j;
|
|
import j0.l.a.a1;
|
|
import j0.l.a.b1;
|
|
import j0.l.a.c0;
|
|
import j0.l.a.c1;
|
|
import j0.l.a.c2;
|
|
import j0.l.a.f;
|
|
import j0.l.a.f0;
|
|
import j0.l.a.f1;
|
|
import j0.l.a.f2;
|
|
import j0.l.a.g0;
|
|
import j0.l.a.g1;
|
|
import j0.l.a.h1;
|
|
import j0.l.a.h2;
|
|
import j0.l.a.i0;
|
|
import j0.l.a.j1;
|
|
import j0.l.a.k0;
|
|
import j0.l.a.k1;
|
|
import j0.l.a.l0;
|
|
import j0.l.a.l1;
|
|
import j0.l.a.n0;
|
|
import j0.l.a.n1;
|
|
import j0.l.a.n2;
|
|
import j0.l.a.o;
|
|
import j0.l.a.o1;
|
|
import j0.l.a.p;
|
|
import j0.l.a.q;
|
|
import j0.l.a.q0;
|
|
import j0.l.a.q2;
|
|
import j0.l.a.r;
|
|
import j0.l.a.r1;
|
|
import j0.l.a.s;
|
|
import j0.l.a.s0;
|
|
import j0.l.a.t1;
|
|
import j0.l.a.u0;
|
|
import j0.l.a.v0;
|
|
import j0.l.a.w0;
|
|
import j0.l.a.x0;
|
|
import j0.l.a.x1;
|
|
import j0.l.a.y;
|
|
import j0.l.a.y1;
|
|
import j0.l.a.z0;
|
|
import j0.l.e.e;
|
|
import j0.l.e.k;
|
|
import j0.l.e.m;
|
|
import j0.o.l;
|
|
import java.util.Arrays;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Objects;
|
|
import java.util.concurrent.Callable;
|
|
import java.util.concurrent.TimeUnit;
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
import rx.Emitter;
|
|
import rx.exceptions.OnErrorFailedException;
|
|
import rx.functions.Action0;
|
|
import rx.functions.Action1;
|
|
import rx.functions.Func0;
|
|
import rx.functions.Func2;
|
|
import rx.functions.Func3;
|
|
import rx.functions.Func4;
|
|
import rx.functions.Func5;
|
|
import rx.functions.Func6;
|
|
import rx.functions.Func7;
|
|
import rx.functions.Func8;
|
|
import rx.functions.Func9;
|
|
import rx.functions.FuncN;
|
|
/* loaded from: classes3.dex */
|
|
public class Observable<T> {
|
|
public final a<T> j;
|
|
|
|
/* loaded from: classes3.dex */
|
|
public interface a<T> extends Action1<Subscriber<? super T>> {
|
|
}
|
|
|
|
/* loaded from: classes3.dex */
|
|
public interface b<R, T> extends j0.k.b<Subscriber<? super R>, Subscriber<? super T>> {
|
|
}
|
|
|
|
/* loaded from: classes3.dex */
|
|
public interface c<T, R> extends j0.k.b<Observable<T>, Observable<R>> {
|
|
}
|
|
|
|
public Observable(a<T> aVar) {
|
|
this.j = aVar;
|
|
}
|
|
|
|
public static <T> Observable<T> A(Iterable<? extends T> iterable) {
|
|
return h0(new q(iterable));
|
|
}
|
|
|
|
public static <T> Observable<T> B(T[] tArr) {
|
|
int length = tArr.length;
|
|
return length == 0 ? (Observable<T>) j0.l.a.c.k : length == 1 ? new k(tArr[0]) : h0(new o(tArr));
|
|
}
|
|
|
|
public static <T> Observable<T> C(Callable<? extends T> callable) {
|
|
return h0(new p(callable));
|
|
}
|
|
|
|
public static Observable<Long> D(long j, long j2, TimeUnit timeUnit) {
|
|
return E(j, j2, timeUnit, j0.p.a.a());
|
|
}
|
|
|
|
public static Observable<Long> E(long j, long j2, TimeUnit timeUnit, Scheduler scheduler) {
|
|
return h0(new k0(j, j2, timeUnit, scheduler));
|
|
}
|
|
|
|
public static <T> Observable<T> G(Observable<? extends Observable<? extends T>> observable) {
|
|
if (observable.getClass() == k.class) {
|
|
return ((k) observable).k0(m.a.INSTANCE);
|
|
}
|
|
return h0(new r(observable.j, x0.b.a));
|
|
}
|
|
|
|
public static <T> Observable<T> H(Observable<? extends T> observable, Observable<? extends T> observable2) {
|
|
return G(B(new Observable[]{observable, observable2}));
|
|
}
|
|
|
|
public static <T, R> Observable<R> b(List<? extends Observable<? extends T>> list, FuncN<? extends R> funcN) {
|
|
return h0(new f(list, funcN));
|
|
}
|
|
|
|
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Observable<R> c(Observable<? extends T1> observable, Observable<? extends T2> observable2, Observable<? extends T3> observable3, Observable<? extends T4> observable4, Observable<? extends T5> observable5, Observable<? extends T6> observable6, Observable<? extends T7> observable7, Observable<? extends T8> observable8, Observable<? extends T9> observable9, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> func9) {
|
|
return b(Arrays.asList(observable, observable2, observable3, observable4, observable5, observable6, observable7, observable8, observable9), new j0.k.c(func9));
|
|
}
|
|
|
|
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> Observable<R> d(Observable<? extends T1> observable, Observable<? extends T2> observable2, Observable<? extends T3> observable3, Observable<? extends T4> observable4, Observable<? extends T5> observable5, Observable<? extends T6> observable6, Observable<? extends T7> observable7, Observable<? extends T8> observable8, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> func8) {
|
|
return b(Arrays.asList(observable, observable2, observable3, observable4, observable5, observable6, observable7, observable8), new j(func8));
|
|
}
|
|
|
|
public static Observable<Long> d0(long j, TimeUnit timeUnit) {
|
|
return e0(j, timeUnit, j0.p.a.a());
|
|
}
|
|
|
|
public static <T1, T2, T3, T4, T5, T6, T7, R> Observable<R> e(Observable<? extends T1> observable, Observable<? extends T2> observable2, Observable<? extends T3> observable3, Observable<? extends T4> observable4, Observable<? extends T5> observable5, Observable<? extends T6> observable6, Observable<? extends T7> observable7, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> func7) {
|
|
return b(Arrays.asList(observable, observable2, observable3, observable4, observable5, observable6, observable7), new i(func7));
|
|
}
|
|
|
|
public static Observable<Long> e0(long j, TimeUnit timeUnit, Scheduler scheduler) {
|
|
return h0(new i0(j, timeUnit, scheduler));
|
|
}
|
|
|
|
public static <T1, T2, T3, T4, T5, T6, R> Observable<R> f(Observable<? extends T1> observable, Observable<? extends T2> observable2, Observable<? extends T3> observable3, Observable<? extends T4> observable4, Observable<? extends T5> observable5, Observable<? extends T6> observable6, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> func6) {
|
|
return b(Arrays.asList(observable, observable2, observable3, observable4, observable5, observable6), new h(func6));
|
|
}
|
|
|
|
public static <T1, T2, T3, T4, T5, R> Observable<R> g(Observable<? extends T1> observable, Observable<? extends T2> observable2, Observable<? extends T3> observable3, Observable<? extends T4> observable4, Observable<? extends T5> observable5, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> func5) {
|
|
return b(Arrays.asList(observable, observable2, observable3, observable4, observable5), new g(func5));
|
|
}
|
|
|
|
public static <T1, T2, T3, T4, R> Observable<R> h(Observable<? extends T1> observable, Observable<? extends T2> observable2, Observable<? extends T3> observable3, Observable<? extends T4> observable4, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> func4) {
|
|
return b(Arrays.asList(observable, observable2, observable3, observable4), new j0.k.f(func4));
|
|
}
|
|
|
|
public static <T> Observable<T> h0(a<T> aVar) {
|
|
return new Observable<>(l.a(aVar));
|
|
}
|
|
|
|
public static <T1, T2, T3, R> Observable<R> i(Observable<? extends T1> observable, Observable<? extends T2> observable2, Observable<? extends T3> observable3, Func3<? super T1, ? super T2, ? super T3, ? extends R> func3) {
|
|
return b(Arrays.asList(observable, observable2, observable3), new e(func3));
|
|
}
|
|
|
|
public static <T1, T2, R> Observable<R> j(Observable<? extends T1> observable, Observable<? extends T2> observable2, Func2<? super T1, ? super T2, ? extends R> func2) {
|
|
return b(Arrays.asList(observable, observable2), new d(func2));
|
|
}
|
|
|
|
public static <T1, T2, R> Observable<R> j0(Observable<? extends T1> observable, Observable<? extends T2> observable2, Func2<? super T1, ? super T2, ? extends R> func2) {
|
|
return h0(new r(new k(new Observable[]{observable, observable2}).j, new q2(func2)));
|
|
}
|
|
|
|
public static <T> Observable<T> l(Observable<? extends Observable<? extends T>> observable) {
|
|
m.a aVar = m.a.INSTANCE;
|
|
Objects.requireNonNull(observable);
|
|
return observable instanceof k ? ((k) observable).k0(aVar) : h0(new j0.l.a.h(observable, aVar, 2, 0));
|
|
}
|
|
|
|
public static <T> Observable<T> m(Observable<? extends T> observable, Observable<? extends T> observable2) {
|
|
return l(B(new Object[]{observable, observable2}));
|
|
}
|
|
|
|
public static <T> Observable<T> n(Action1<Emitter<T>> action1, Emitter.BackpressureMode backpressureMode) {
|
|
return h0(new j0.l.a.i(action1, backpressureMode));
|
|
}
|
|
|
|
public static <T> Observable<T> w(Throwable th) {
|
|
return h0(new f0(th));
|
|
}
|
|
|
|
public final <R> Observable<R> F(j0.k.b<? super T, ? extends R> bVar) {
|
|
return h0(new s(this, bVar));
|
|
}
|
|
|
|
public final Observable<T> I(Scheduler scheduler) {
|
|
int i = j0.l.e.i.j;
|
|
if (this instanceof k) {
|
|
return ((k) this).l0(scheduler);
|
|
}
|
|
return h0(new r(this.j, new z0(scheduler, false, i)));
|
|
}
|
|
|
|
public final Observable<T> J() {
|
|
return h0(new r(this.j, a1.b.a));
|
|
}
|
|
|
|
public final Observable<T> K() {
|
|
return h0(new r(this.j, b1.a.a));
|
|
}
|
|
|
|
public final Observable<T> L(j0.k.b<? super Throwable, ? extends T> bVar) {
|
|
return h0(new r(this.j, new f1(new c1(bVar))));
|
|
}
|
|
|
|
public final j0.m.b<T> M(int i) {
|
|
if (i == Integer.MAX_VALUE) {
|
|
Func0 func0 = j1.k;
|
|
AtomicReference atomicReference = new AtomicReference();
|
|
return new j1(new l1(atomicReference, func0), this, atomicReference, func0);
|
|
}
|
|
k1 k1Var = new k1(i);
|
|
AtomicReference atomicReference2 = new AtomicReference();
|
|
return new j1(new l1(atomicReference2, k1Var), this, atomicReference2, k1Var);
|
|
}
|
|
|
|
public final Observable<T> N(j0.k.b<? super Observable<? extends Throwable>, ? extends Observable<?>> bVar) {
|
|
e.d dVar = new e.d(bVar);
|
|
AtomicReference<j0.p.a> atomicReference = j0.p.a.a;
|
|
return h0(new y(this, dVar, true, false, j0.l.c.m.a));
|
|
}
|
|
|
|
public final Observable<T> O(long j, TimeUnit timeUnit) {
|
|
return h0(new r(this.j, new n1(j, timeUnit, j0.p.a.a())));
|
|
}
|
|
|
|
public final <R> Observable<R> P(R r, Func2<R, ? super T, R> func2) {
|
|
return h0(new r(this.j, new o1(r, func2)));
|
|
}
|
|
|
|
public final Observable<T> Q() {
|
|
AtomicReference atomicReference = new AtomicReference();
|
|
return h0(new c0(new h1(new g1(atomicReference), this, atomicReference)));
|
|
}
|
|
|
|
public final Observable<T> R() {
|
|
return h0(new r(this.j, r1.a.a));
|
|
}
|
|
|
|
public final Observable<T> S(int i) {
|
|
return h0(new r(this.j, new t1(i)));
|
|
}
|
|
|
|
public final Observable<T> T(T t) {
|
|
return m(new k(t), this);
|
|
}
|
|
|
|
public final Subscription U(Subscriber<? super T> subscriber) {
|
|
if (subscriber == null) {
|
|
throw new IllegalArgumentException("subscriber can not be null");
|
|
} else if (this.j != null) {
|
|
subscriber.onStart();
|
|
if (!(subscriber instanceof j0.n.b)) {
|
|
subscriber = new j0.n.b<>(subscriber);
|
|
}
|
|
try {
|
|
a aVar = this.j;
|
|
Func2<Observable, a, a> func2 = l.e;
|
|
if (func2 != null) {
|
|
aVar = func2.call(this, aVar);
|
|
}
|
|
aVar.call(subscriber);
|
|
j0.k.b<Subscription, Subscription> bVar = l.g;
|
|
return bVar != null ? bVar.call(subscriber) : subscriber;
|
|
} catch (Throwable th) {
|
|
b.i.a.f.e.o.f.o1(th);
|
|
if (subscriber.isUnsubscribed()) {
|
|
l.b(l.c(th));
|
|
} else {
|
|
try {
|
|
subscriber.onError(l.c(th));
|
|
} catch (Throwable th2) {
|
|
b.i.a.f.e.o.f.o1(th2);
|
|
StringBuilder R = b.d.b.a.a.R("Error occurred attempting to subscribe [");
|
|
R.append(th.getMessage());
|
|
R.append("] and then again while trying to pass to onError.");
|
|
OnErrorFailedException onErrorFailedException = new OnErrorFailedException(R.toString(), th2);
|
|
l.c(onErrorFailedException);
|
|
throw onErrorFailedException;
|
|
}
|
|
}
|
|
return j0.r.c.a;
|
|
}
|
|
} else {
|
|
throw new IllegalStateException("onSubscribe function can not be null.");
|
|
}
|
|
}
|
|
|
|
public final Subscription V(Action1<? super T> action1) {
|
|
return U(new j0.l.e.b(action1, j0.l.e.e.l, j0.k.a.a));
|
|
}
|
|
|
|
public final Subscription W(Action1<? super T> action1, Action1<Throwable> action12) {
|
|
if (action1 == null) {
|
|
throw new IllegalArgumentException("onNext can not be null");
|
|
} else if (action12 != null) {
|
|
return U(new j0.l.e.b(action1, action12, j0.k.a.a));
|
|
} else {
|
|
throw new IllegalArgumentException("onError can not be null");
|
|
}
|
|
}
|
|
|
|
public final Observable<T> X(Scheduler scheduler) {
|
|
return this instanceof k ? ((k) this).l0(scheduler) : h0(new x1(this, scheduler, !(this.j instanceof j0.l.a.i)));
|
|
}
|
|
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
public final <R> Observable<R> Y(j0.k.b<? super T, ? extends Observable<? extends R>> bVar) {
|
|
Observable<R> F = F(bVar);
|
|
return h0(new r(F.j, y1.a.a));
|
|
}
|
|
|
|
public final Observable<T> Z(int i) {
|
|
return h0(new r(this.j, new c2(i)));
|
|
}
|
|
|
|
public final Observable<List<T>> a(long j, TimeUnit timeUnit) {
|
|
return h0(new r(this.j, new n0(j, j, timeUnit, Integer.MAX_VALUE, j0.p.a.a())));
|
|
}
|
|
|
|
public final <E> Observable<T> a0(Observable<? extends E> observable) {
|
|
return h0(new r(this.j, new f2(observable)));
|
|
}
|
|
|
|
public final Observable<T> b0(j0.k.b<? super T, Boolean> bVar) {
|
|
return h0(new r(this.j, new h2(bVar)));
|
|
}
|
|
|
|
public final Observable<T> c0(long j, TimeUnit timeUnit) {
|
|
return h0(new g0(this, j, timeUnit, j0.p.a.a(), null));
|
|
}
|
|
|
|
public final Observable<List<T>> f0() {
|
|
return h0(new r(this.j, n2.a.a));
|
|
}
|
|
|
|
public final <K, V> Observable<Map<K, V>> g0(j0.k.b<? super T, ? extends K> bVar, j0.k.b<? super T, ? extends V> bVar2) {
|
|
return h0(new l0(this, bVar, bVar2));
|
|
}
|
|
|
|
public final Subscription i0(Subscriber<? super T> subscriber) {
|
|
try {
|
|
subscriber.onStart();
|
|
a aVar = this.j;
|
|
Func2<Observable, a, a> func2 = l.e;
|
|
if (func2 != null) {
|
|
aVar = func2.call(this, aVar);
|
|
}
|
|
aVar.call(subscriber);
|
|
j0.k.b<Subscription, Subscription> bVar = l.g;
|
|
return bVar != null ? bVar.call(subscriber) : subscriber;
|
|
} catch (Throwable th) {
|
|
b.i.a.f.e.o.f.o1(th);
|
|
try {
|
|
subscriber.onError(l.c(th));
|
|
return j0.r.c.a;
|
|
} catch (Throwable th2) {
|
|
b.i.a.f.e.o.f.o1(th2);
|
|
StringBuilder R = b.d.b.a.a.R("Error occurred attempting to subscribe [");
|
|
R.append(th.getMessage());
|
|
R.append("] and then again while trying to pass to onError.");
|
|
OnErrorFailedException onErrorFailedException = new OnErrorFailedException(R.toString(), th2);
|
|
l.c(onErrorFailedException);
|
|
throw onErrorFailedException;
|
|
}
|
|
}
|
|
}
|
|
|
|
public <R> Observable<R> k(c<? super T, ? extends R> cVar) {
|
|
return (Observable) cVar.call(this);
|
|
}
|
|
|
|
public final Observable<T> o(long j, TimeUnit timeUnit) {
|
|
return h0(new r(this.j, new q0(j, timeUnit, j0.p.a.a())));
|
|
}
|
|
|
|
public final Observable<T> p(long j, TimeUnit timeUnit) {
|
|
return h0(new r(this.j, new s0(j, timeUnit, j0.p.a.a())));
|
|
}
|
|
|
|
public final Observable<T> q() {
|
|
return h0(new r(this.j, u0.a.a));
|
|
}
|
|
|
|
public final Observable<T> r(Func2<? super T, ? super T, Boolean> func2) {
|
|
return h0(new r(this.j, new u0(func2)));
|
|
}
|
|
|
|
public final Observable<T> s(Action1<? super Throwable> action1) {
|
|
a.C0393a aVar = j0.k.a.a;
|
|
return h0(new j0.l.a.k(this, new j0.l.e.a(aVar, action1, aVar)));
|
|
}
|
|
|
|
public final Observable<T> t(Action1<? super T> action1) {
|
|
a.C0393a aVar = j0.k.a.a;
|
|
return h0(new j0.l.a.k(this, new j0.l.e.a(action1, aVar, aVar)));
|
|
}
|
|
|
|
public final Observable<T> u(Action0 action0) {
|
|
return h0(new r(this.j, new v0(action0)));
|
|
}
|
|
|
|
public final Observable<T> v(Action0 action0) {
|
|
return h0(new r(this.j, new w0(action0)));
|
|
}
|
|
|
|
public final Observable<T> x(j0.k.b<? super T, Boolean> bVar) {
|
|
return h0(new j0.l.a.l(this, bVar));
|
|
}
|
|
|
|
public final Observable<T> y() {
|
|
return Z(1).R();
|
|
}
|
|
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
public final <R> Observable<R> z(j0.k.b<? super T, ? extends Observable<? extends R>> bVar) {
|
|
return getClass() == k.class ? ((k) this).k0(bVar) : G(F(bVar));
|
|
}
|
|
}
|