discord-jadx/app/src/main/java/rx/Observable.java

package rx;

import i0.k.a;
import i0.k.d;
import i0.k.e;
import i0.k.g;
import i0.k.h;
import i0.k.i;
import i0.l.a.a1;
import i0.l.a.b1;
import i0.l.a.c0;
import i0.l.a.c1;
import i0.l.a.c2;
import i0.l.a.f;
import i0.l.a.f0;
import i0.l.a.f1;
import i0.l.a.f2;
import i0.l.a.g0;
import i0.l.a.g1;
import i0.l.a.h1;
import i0.l.a.h2;
import i0.l.a.i0;
import i0.l.a.j1;
import i0.l.a.k;
import i0.l.a.k0;
import i0.l.a.k1;
import i0.l.a.l0;
import i0.l.a.l1;
import i0.l.a.n0;
import i0.l.a.n1;
import i0.l.a.n2;
import i0.l.a.o;
import i0.l.a.o1;
import i0.l.a.p;
import i0.l.a.q;
import i0.l.a.q0;
import i0.l.a.q2;
import i0.l.a.r;
import i0.l.a.r1;
import i0.l.a.s;
import i0.l.a.s0;
import i0.l.a.t1;
import i0.l.a.u0;
import i0.l.a.v0;
import i0.l.a.w0;
import i0.l.a.x0;
import i0.l.a.x1;
import i0.l.a.y;
import i0.l.a.y1;
import i0.l.a.z0;
import i0.l.c.m;
import i0.l.e.e;
import i0.l.e.j;
import i0.l.e.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;
public class Observable<T> {
    public final a<T> i;

    public interface a<T> extends Action1<Subscriber<? super T>> {
    }

    public interface b<R, T> extends i0.k.b<Subscriber<? super R>, Subscriber<? super T>> {
    }

    public interface c<T, R> extends i0.k.b<Observable<T>, Observable<R>> {
    }

    public Observable(a<T> aVar) {
        this.i = aVar;
    }

    public static <T> Observable<T> A(T[] tArr) {
        int length = tArr.length;
        return length == 0 ? (Observable<T>) i0.l.a.c.j : length == 1 ? new j(tArr[0]) : g0(new o(tArr));
    }

    public static <T> Observable<T> B(Callable<? extends T> callable) {
        return g0(new p(callable));
    }

    public static Observable<Long> C(long j, long j2, TimeUnit timeUnit) {
        return D(j, j2, timeUnit, i0.p.a.a());
    }

    public static Observable<Long> D(long j, long j2, TimeUnit timeUnit, Scheduler scheduler) {
        return g0(new k0(j, j2, timeUnit, scheduler));
    }

    public static <T> Observable<T> F(Observable<? extends Observable<? extends T>> observable) {
        if (observable.getClass() == j.class) {
            return ((j) observable).j0(l.INSTANCE);
        }
        return g0(new r(observable.i, x0.b.a));
    }

    public static <T> Observable<T> G(Observable<? extends T> observable, Observable<? extends T> observable2) {
        return F(A(new Observable[]{observable, observable2}));
    }

    public static <T, R> Observable<R> b(List<? extends Observable<? extends T>> list, FuncN<? extends R> funcN) {
        return g0(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 i0.k.c(func9));
    }

    public static Observable<Long> c0(long j, TimeUnit timeUnit) {
        return d0(j, timeUnit, i0.p.a.a());
    }

    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 i0.k.j(func8));
    }

    public static Observable<Long> d0(long j, TimeUnit timeUnit, Scheduler scheduler) {
        return g0(new i0(j, timeUnit, scheduler));
    }

    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 <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 <T> Observable<T> g0(a<T> aVar) {
        return new Observable<>(i0.o.l.a(aVar));
    }

    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 i0.k.f(func4));
    }

    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> i0(Observable<? extends T1> observable, Observable<? extends T2> observable2, Func2<? super T1, ? super T2, ? extends R> func2) {
        return g0(new r(new j(new Observable[]{observable, observable2}).i, new q2(func2)));
    }

    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 <T> Observable<T> l(Observable<? extends Observable<? extends T>> observable) {
        l lVar = l.INSTANCE;
        Objects.requireNonNull(observable);
        return observable instanceof j ? ((j) observable).j0(lVar) : g0(new i0.l.a.h(observable, lVar, 2, 0));
    }

    public static <T> Observable<T> m(Observable<? extends T> observable, Observable<? extends T> observable2) {
        return l(A(new Object[]{observable, observable2}));
    }

    public static <T> Observable<T> n(Action1<Emitter<T>> action1, Emitter.BackpressureMode backpressureMode) {
        return g0(new i0.l.a.i(action1, backpressureMode));
    }

    public static <T> Observable<T> v(Throwable th) {
        return g0(new f0(th));
    }

    public static <T> Observable<T> z(Iterable<? extends T> iterable) {
        return g0(new q(iterable));
    }

    public final <R> Observable<R> E(i0.k.b<? super T, ? extends R> bVar) {
        return g0(new s(this, bVar));
    }

    public final Observable<T> H(Scheduler scheduler) {
        int i = i0.l.e.h.i;
        if (this instanceof j) {
            return ((j) this).k0(scheduler);
        }
        return g0(new r(this.i, new z0(scheduler, false, i)));
    }

    public final Observable<T> I() {
        return g0(new r(this.i, a1.b.a));
    }

    public final Observable<T> J() {
        return g0(new r(this.i, b1.a.a));
    }

    public final Observable<T> K(i0.k.b<? super Throwable, ? extends T> bVar) {
        return g0(new r(this.i, new f1(new c1(bVar))));
    }

    public final i0.m.b<T> L(int i) {
        if (i == Integer.MAX_VALUE) {
            Func0 func0 = j1.j;
            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> M(i0.k.b<? super Observable<? extends Throwable>, ? extends Observable<?>> bVar) {
        e.d dVar = new e.d(bVar);
        AtomicReference<i0.p.a> atomicReference = i0.p.a.a;
        return g0(new y(this, dVar, true, false, m.a));
    }

    public final Observable<T> N(long j, TimeUnit timeUnit) {
        return g0(new r(this.i, new n1(j, timeUnit, i0.p.a.a())));
    }

    public final <R> Observable<R> O(R r2, Func2<R, ? super T, R> func2) {
        return g0(new r(this.i, new o1(r2, func2)));
    }

    public final Observable<T> P() {
        AtomicReference atomicReference = new AtomicReference();
        return g0(new c0(new h1(new g1(atomicReference), this, atomicReference)));
    }

    public final Observable<T> Q() {
        return g0(new r(this.i, r1.a.a));
    }

    public final Observable<T> R(int i) {
        return g0(new r(this.i, new t1(i)));
    }

    public final Observable<T> S(T t) {
        return m(new j(t), this);
    }

    /* JADX WARN: Multi-variable type inference failed */
    public final Subscription T(Subscriber<? super T> subscriber) {
        if (subscriber == null) {
            throw new IllegalArgumentException("subscriber can not be null");
        } else if (this.i != null) {
            subscriber.onStart();
            if (!(subscriber instanceof i0.n.b)) {
                subscriber = new i0.n.b(subscriber);
            }
            try {
                a<T> aVar = this.i;
                Func2<Observable, a, a> func2 = i0.o.l.e;
                a<T> aVar2 = aVar;
                if (func2 != null) {
                    aVar2 = (a<T>) func2.call(this, aVar);
                }
                aVar2.call(subscriber);
                i0.k.b<Subscription, Subscription> bVar = i0.o.l.g;
                return bVar != null ? bVar.call(subscriber) : subscriber;
            } catch (Throwable th) {
                c.q.a.k.a.b0(th);
                StringBuilder O = c.d.b.a.a.O("Error occurred attempting to subscribe [");
                O.append(th.getMessage());
                O.append("] and then again while trying to pass to onError.");
                OnErrorFailedException onErrorFailedException = new OnErrorFailedException(O.toString(), th);
                i0.o.l.c(onErrorFailedException);
                throw onErrorFailedException;
            }
        } else {
            throw new IllegalStateException("onSubscribe function can not be null.");
        }
    }

    public final Subscription U(Action1<? super T> action1) {
        return T(new i0.l.e.b(action1, i0.l.e.e.k, i0.k.a.a));
    }

    public final Subscription V(Action1<? super T> action1, Action1<Throwable> action12) {
        if (action1 == null) {
            throw new IllegalArgumentException("onNext can not be null");
        } else if (action12 != null) {
            return T(new i0.l.e.b(action1, action12, i0.k.a.a));
        } else {
            throw new IllegalArgumentException("onError can not be null");
        }
    }

    public final Observable<T> W(Scheduler scheduler) {
        return this instanceof j ? ((j) this).k0(scheduler) : g0(new x1(this, scheduler, !(this.i instanceof i0.l.a.i)));
    }

    /* JADX DEBUG: Multi-variable search result rejected for r3v0, resolved type: i0.k.b<? super T, ? extends rx.Observable<? extends R>> */
    /* JADX WARN: Multi-variable type inference failed */
    public final <R> Observable<R> X(i0.k.b<? super T, ? extends Observable<? extends R>> bVar) {
        Observable<R> E = E(bVar);
        return g0(new r(E.i, y1.a.a));
    }

    public final Observable<T> Y(int i) {
        return g0(new r(this.i, new c2(i)));
    }

    public final <E> Observable<T> Z(Observable<? extends E> observable) {
        return g0(new r(this.i, new f2(observable)));
    }

    public final Observable<List<T>> a(long j, TimeUnit timeUnit) {
        return g0(new r(this.i, new n0(j, j, timeUnit, Integer.MAX_VALUE, i0.p.a.a())));
    }

    public final Observable<T> a0(i0.k.b<? super T, Boolean> bVar) {
        return g0(new r(this.i, new h2(bVar)));
    }

    public final Observable<T> b0(long j, TimeUnit timeUnit) {
        return g0(new g0(this, j, timeUnit, i0.p.a.a(), null));
    }

    public final Observable<List<T>> e0() {
        return g0(new r(this.i, n2.a.a));
    }

    public final <K, V> Observable<Map<K, V>> f0(i0.k.b<? super T, ? extends K> bVar, i0.k.b<? super T, ? extends V> bVar2) {
        return g0(new l0(this, bVar, bVar2));
    }

    public final Subscription h0(Subscriber<? super T> subscriber) {
        try {
            subscriber.onStart();
            a aVar = this.i;
            Func2<Observable, a, a> func2 = i0.o.l.e;
            if (func2 != null) {
                aVar = func2.call(this, aVar);
            }
            aVar.call(subscriber);
            i0.k.b<Subscription, Subscription> bVar = i0.o.l.g;
            return bVar != null ? bVar.call(subscriber) : subscriber;
        } catch (Throwable th) {
            c.q.a.k.a.b0(th);
            StringBuilder O = c.d.b.a.a.O("Error occurred attempting to subscribe [");
            O.append(th.getMessage());
            O.append("] and then again while trying to pass to onError.");
            OnErrorFailedException onErrorFailedException = new OnErrorFailedException(O.toString(), th);
            i0.o.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 g0(new r(this.i, new q0(j, timeUnit, i0.p.a.a())));
    }

    public final Observable<T> p(long j, TimeUnit timeUnit) {
        return g0(new r(this.i, new s0(j, timeUnit, i0.p.a.a())));
    }

    public final Observable<T> q() {
        return g0(new r(this.i, u0.a.a));
    }

    public final Observable<T> r(Action1<? super Throwable> action1) {
        a.C0323a aVar = i0.k.a.a;
        return g0(new k(this, new i0.l.e.a(aVar, action1, aVar)));
    }

    public final Observable<T> s(Action1<? super T> action1) {
        a.C0323a aVar = i0.k.a.a;
        return g0(new k(this, new i0.l.e.a(action1, aVar, aVar)));
    }

    public final Observable<T> t(Action0 action0) {
        return g0(new r(this.i, new v0(action0)));
    }

    public final Observable<T> u(Action0 action0) {
        return g0(new r(this.i, new w0(action0)));
    }

    public final Observable<T> w(i0.k.b<? super T, Boolean> bVar) {
        return g0(new i0.l.a.l(this, bVar));
    }

    public final Observable<T> x() {
        return Y(1).Q();
    }

    /* JADX DEBUG: Multi-variable search result rejected for r3v0, resolved type: i0.k.b<? super T, ? extends rx.Observable<? extends R>> */
    /* JADX WARN: Multi-variable type inference failed */
    public final <R> Observable<R> y(i0.k.b<? super T, ? extends Observable<? extends R>> bVar) {
        return getClass() == j.class ? ((j) this).j0(bVar) : F(E(bVar));
    }
}