灵犀直播 v1.0.127版本的 MD5 值为：a63989b077d9456fb57c6835ee2849a1

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

package e.a;
public abstract class e<T> implements h<T> {
    public static int b() {
        return c.a();
    }

    public static <T> e<T> c(g<T> gVar) {
        e.a.p.b.b.c(gVar, "source is null");
        return e.a.q.a.j(new e.a.p.e.a.b(gVar));
    }

    @Override
    public final void a(i<? super T> iVar) {
        e.a.p.b.b.c(iVar, "observer is null");
        try {
            i<? super T> n = e.a.q.a.n(this, iVar);
            e.a.p.b.b.c(n, "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");
            h(n);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            e.a.n.b.b(th);
            e.a.q.a.k(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final e<T> d(j jVar) {
        return e(jVar, false, b());
    }

    public final e<T> e(j jVar, boolean z, int i) {
        e.a.p.b.b.c(jVar, "scheduler is null");
        e.a.p.b.b.d(i, "bufferSize");
        return e.a.q.a.j(new e.a.p.e.a.c(this, jVar, z, i));
    }

    public final e.a.m.b f(e.a.o.e<? super T> eVar) {
        return g(eVar, e.a.p.b.a.f6136f, e.a.p.b.a.f6133c, e.a.p.b.a.a());
    }

    public final e.a.m.b g(e.a.o.e<? super T> eVar, e.a.o.e<? super Throwable> eVar2, e.a.o.a aVar, e.a.o.e<? super e.a.m.b> eVar3) {
        e.a.p.b.b.c(eVar, "onNext is null");
        e.a.p.b.b.c(eVar2, "onError is null");
        e.a.p.b.b.c(aVar, "onComplete is null");
        e.a.p.b.b.c(eVar3, "onSubscribe is null");
        e.a.p.d.b bVar = new e.a.p.d.b(eVar, eVar2, aVar, eVar3);
        a(bVar);
        return bVar;
    }

    public abstract void h(i<? super T> iVar);

    public final e<T> i(j jVar) {
        e.a.p.b.b.c(jVar, "scheduler is null");
        return e.a.q.a.j(new e.a.p.e.a.d(this, jVar));
    }
}