同程有借 v1.0.0版本的 MD5 值为：e33397cdbab33543d0c134ec96d77fb8

以下内容为反编译后的 e.java 源代码，内容仅作参考

package n6;

import io.reactivex.internal.operators.observable.k;
import io.reactivex.internal.operators.observable.l;
import io.reactivex.internal.operators.observable.m;
import io.reactivex.internal.operators.observable.n;
import io.reactivex.internal.operators.observable.o;
import io.reactivex.internal.operators.observable.p;
import io.reactivex.internal.operators.observable.q;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.Callable;
public abstract class e<T> implements f<T> {

    static class a {
        static final int[] f18897a;

        static {
            int[] iArr = new int[n6.a.values().length];
            f18897a = iArr;
            try {
                iArr[n6.a.DROP.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            try {
                f18897a[n6.a.LATEST.ordinal()] = 2;
            } catch (NoSuchFieldError unused2) {
            }
            try {
                f18897a[n6.a.MISSING.ordinal()] = 3;
            } catch (NoSuchFieldError unused3) {
            }
            try {
                f18897a[n6.a.ERROR.ordinal()] = 4;
            } catch (NoSuchFieldError unused4) {
            }
        }
    }

    public static <T> e<T> I(f<T> fVar) {
        t6.b.d(fVar, "source is null");
        if (fVar instanceof e) {
            return x6.a.m((e) fVar);
        }
        return x6.a.m(new io.reactivex.internal.operators.observable.i(fVar));
    }

    public static int h() {
        return c.a();
    }

    public static <T> e<T> j(f<? extends f<? extends T>> fVar) {
        return k(fVar, h());
    }

    public static <T> e<T> k(f<? extends f<? extends T>> fVar, int i9) {
        t6.b.d(fVar, "sources is null");
        t6.b.e(i9, "prefetch");
        return x6.a.m(new io.reactivex.internal.operators.observable.c(fVar, t6.a.b(), i9, io.reactivex.internal.util.d.IMMEDIATE));
    }

    public static <T> e<T> l() {
        return x6.a.m(io.reactivex.internal.operators.observable.d.f18120a);
    }

    public static <T> e<T> m(Throwable th) {
        t6.b.d(th, "exception is null");
        return n(t6.a.c(th));
    }

    public static <T> e<T> n(Callable<? extends Throwable> callable) {
        t6.b.d(callable, "errorSupplier is null");
        return x6.a.m(new io.reactivex.internal.operators.observable.e(callable));
    }

    public static <T> e<T> s(T... tArr) {
        t6.b.d(tArr, "items is null");
        if (tArr.length == 0) {
            return l();
        }
        if (tArr.length == 1) {
            return v(tArr[0]);
        }
        return x6.a.m(new io.reactivex.internal.operators.observable.g(tArr));
    }

    public static <T> e<T> t(Iterable<? extends T> iterable) {
        t6.b.d(iterable, "source is null");
        return x6.a.m(new io.reactivex.internal.operators.observable.h(iterable));
    }

    public static <T> e<T> v(T t9) {
        t6.b.d(t9, "item is null");
        return x6.a.m(new k(t9));
    }

    public static <T> e<T> w(f<? extends T> fVar, f<? extends T> fVar2) {
        t6.b.d(fVar, "source1 is null");
        t6.b.d(fVar2, "source2 is null");
        return s(fVar, fVar2).q(t6.a.b(), false, 2);
    }

    public final j<T> A() {
        return x6.a.n(new o(this, null));
    }

    public final q6.b B(r6.c<? super T> cVar) {
        return D(cVar, t6.a.f20150e, t6.a.f20148c, t6.a.a());
    }

    public final q6.b C(r6.c<? super T> cVar, r6.c<? super Throwable> cVar2, r6.a aVar) {
        return D(cVar, cVar2, aVar, t6.a.a());
    }

    public final q6.b D(r6.c<? super T> cVar, r6.c<? super Throwable> cVar2, r6.a aVar, r6.c<? super q6.b> cVar3) {
        t6.b.d(cVar, "onNext is null");
        t6.b.d(cVar2, "onError is null");
        t6.b.d(aVar, "onComplete is null");
        t6.b.d(cVar3, "onSubscribe is null");
        io.reactivex.internal.observers.c cVar4 = new io.reactivex.internal.observers.c(cVar, cVar2, aVar, cVar3);
        c(cVar4);
        return cVar4;
    }

    protected abstract void E(h<? super T> hVar);

    public final e<T> F(i iVar) {
        t6.b.d(iVar, "scheduler is null");
        return x6.a.m(new p(this, iVar));
    }

    public final c<T> G(n6.a aVar) {
        v6.b bVar = new v6.b(this);
        int i9 = a.f18897a[aVar.ordinal()];
        if (i9 != 1) {
            if (i9 != 2) {
                if (i9 != 3) {
                    if (i9 != 4) {
                        return bVar.b();
                    }
                    return x6.a.k(new v6.e(bVar));
                }
                return bVar;
            }
            return bVar.e();
        }
        return bVar.d();
    }

    public final e<T> H(i iVar) {
        t6.b.d(iVar, "scheduler is null");
        return x6.a.m(new q(this, iVar));
    }

    @Override
    public final void c(h<? super T> hVar) {
        t6.b.d(hVar, "observer is null");
        try {
            h<? super T> r9 = x6.a.r(this, hVar);
            t6.b.d(r9, "The RxJavaPlugins.onSubscribe hook returned a null Observer. Please change the handler provided to RxJavaPlugins.setOnObservableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
            E(r9);
        } catch (NullPointerException e9) {
            throw e9;
        } catch (Throwable th) {
            io.reactivex.exceptions.b.b(th);
            x6.a.o(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final e<List<T>> e(int i9) {
        return f(i9, i9);
    }

    public final e<List<T>> f(int i9, int i10) {
        return (e<List<T>>) g(i9, i10, io.reactivex.internal.util.b.e());
    }

    public final <U extends Collection<? super T>> e<U> g(int i9, int i10, Callable<U> callable) {
        t6.b.e(i9, "count");
        t6.b.e(i10, "skip");
        t6.b.d(callable, "bufferSupplier is null");
        return x6.a.m(new io.reactivex.internal.operators.observable.b(this, i9, i10, callable));
    }

    public final <R> e<R> i(g<? super T, ? extends R> gVar) {
        return I(((g) t6.b.d(gVar, "composer is null")).a(this));
    }

    public final <R> e<R> o(r6.d<? super T, ? extends f<? extends R>> dVar) {
        return p(dVar, false);
    }

    public final <R> e<R> p(r6.d<? super T, ? extends f<? extends R>> dVar, boolean z8) {
        return q(dVar, z8, Integer.MAX_VALUE);
    }

    public final <R> e<R> q(r6.d<? super T, ? extends f<? extends R>> dVar, boolean z8, int i9) {
        return r(dVar, z8, i9, h());
    }

    public final <R> e<R> r(r6.d<? super T, ? extends f<? extends R>> dVar, boolean z8, int i9, int i10) {
        t6.b.d(dVar, "mapper is null");
        t6.b.e(i9, "maxConcurrency");
        t6.b.e(i10, "bufferSize");
        if (this instanceof u6.c) {
            Object call = ((u6.c) this).call();
            if (call == null) {
                return l();
            }
            return m.a(call, dVar);
        }
        return x6.a.m(new io.reactivex.internal.operators.observable.f(this, dVar, z8, i9, i10));
    }

    public final b u() {
        return x6.a.j(new io.reactivex.internal.operators.observable.j(this));
    }

    public final e<T> x(i iVar) {
        return y(iVar, false, h());
    }

    public final e<T> y(i iVar, boolean z8, int i9) {
        t6.b.d(iVar, "scheduler is null");
        t6.b.e(i9, "bufferSize");
        return x6.a.m(new l(this, iVar, z8, i9));
    }

    public final d<T> z() {
        return x6.a.l(new n(this));
    }
}