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

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

package w7;

import java.util.NoSuchElementException;
import java.util.concurrent.Callable;
public abstract class f<T> implements j<T> {
    public static <T> f<T> b(i<T> iVar) {
        d8.b.c(iVar, "source is null");
        return m8.a.k(new i8.a(iVar));
    }

    public static <T> f<T> c(Throwable th) {
        d8.b.c(th, "exception is null");
        return d(d8.a.b(th));
    }

    public static <T> f<T> d(Callable<? extends Throwable> callable) {
        d8.b.c(callable, "errorSupplier is null");
        return m8.a.k(new i8.b(callable));
    }

    public static <T1, T2, R> f<R> j(j<? extends T1> jVar, j<? extends T2> jVar2, b8.b<? super T1, ? super T2, ? extends R> bVar) {
        d8.b.c(jVar, "source1 is null");
        d8.b.c(jVar2, "source2 is null");
        return k(d8.a.c(bVar), jVar, jVar2);
    }

    public static <T, R> f<R> k(b8.e<? super Object[], ? extends R> eVar, j<? extends T>... jVarArr) {
        d8.b.c(eVar, "zipper is null");
        d8.b.c(jVarArr, "sources is null");
        return jVarArr.length == 0 ? c(new NoSuchElementException()) : m8.a.k(new i8.f(jVarArr, eVar));
    }

    @Override
    public final void a(h<? super T> hVar) {
        d8.b.c(hVar, "observer is null");
        h<? super T> p9 = m8.a.p(this, hVar);
        d8.b.c(p9, "The RxJavaPlugins.onSubscribe hook returned a null SingleObserver. Please check the handler provided to RxJavaPlugins.setOnSingleSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
        try {
            h(p9);
        } catch (NullPointerException e9) {
            throw e9;
        } catch (Throwable th) {
            a8.b.b(th);
            NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final <R> b<R> e(b8.e<? super T, ? extends c<? extends R>> eVar) {
        d8.b.c(eVar, "mapper is null");
        return m8.a.j(new g8.a(this, eVar));
    }

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

    public final z7.b g(b8.d<? super T> dVar, b8.d<? super Throwable> dVar2) {
        d8.b.c(dVar, "onSuccess is null");
        d8.b.c(dVar2, "onError is null");
        f8.b bVar = new f8.b(dVar, dVar2);
        a(bVar);
        return bVar;
    }

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

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