MEGA STAR IPTV v3.4版本的 MD5 值为：f68c82adeb6c1166a42c50cbe0c3cfa6

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

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

    public static <T> b<T> c(T t9) {
        d8.b.c(t9, "item is null");
        return m8.a.j(new h8.b(t9));
    }

    @Override
    public final void a(d<? super T> dVar) {
        d8.b.c(dVar, "observer is null");
        try {
            d<? super T> o9 = m8.a.o(this, dVar);
            d8.b.c(o9, "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");
            i(o9);
        } catch (NullPointerException e9) {
            throw e9;
        } catch (Throwable th) {
            a8.b.b(th);
            m8.a.l(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

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

    public final b<T> e(e eVar, boolean z9, int i9) {
        d8.b.c(eVar, "scheduler is null");
        d8.b.d(i9, "bufferSize");
        return m8.a.j(new h8.c(this, eVar, z9, i9));
    }

    public final f<T> f() {
        return m8.a.k(new h8.e(this, null));
    }

    public final z7.b g(b8.d<? super T> dVar, b8.d<? super Throwable> dVar2) {
        return h(dVar, dVar2, d8.a.f6047c, d8.a.a());
    }

    public final z7.b h(b8.d<? super T> dVar, b8.d<? super Throwable> dVar2, b8.a aVar, b8.d<? super z7.b> dVar3) {
        d8.b.c(dVar, "onNext is null");
        d8.b.c(dVar2, "onError is null");
        d8.b.c(aVar, "onComplete is null");
        d8.b.c(dVar3, "onSubscribe is null");
        f8.c cVar = new f8.c(dVar, dVar2, aVar, dVar3);
        a(cVar);
        return cVar;
    }

    protected abstract void i(d<? super T> dVar);

    public final b<T> j(e eVar) {
        d8.b.c(eVar, "scheduler is null");
        return m8.a.j(new h8.f(this, eVar));
    }
}