AdGuard v4.4.135版本的 MD5 值为：95950267eaafbda3588f0934f48b2e36

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

package jb;

import java.util.Objects;
public abstract class d<T> implements e<T> {
    public static int e() {
        return b.a();
    }

    @Override
    public final void d(f<? super T> fVar) {
        Objects.requireNonNull(fVar, "observer is null");
        try {
            f<? super T> m10 = vb.a.m(this, fVar);
            Objects.requireNonNull(m10, "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");
            n(m10);
        } catch (NullPointerException e10) {
            throw e10;
        } catch (Throwable th2) {
            lb.b.b(th2);
            vb.a.j(th2);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th2);
            throw nullPointerException;
        }
    }

    public final <U> d<U> f(Class<U> cls) {
        Objects.requireNonNull(cls, "clazz is null");
        return (d<U>) h(ob.a.a(cls));
    }

    public final d<T> g(mb.f<? super T> fVar) {
        Objects.requireNonNull(fVar, "predicate is null");
        return vb.a.i(new rb.b(this, fVar));
    }

    public final <R> d<R> h(mb.d<? super T, ? extends R> dVar) {
        Objects.requireNonNull(dVar, "mapper is null");
        return vb.a.i(new rb.c(this, dVar));
    }

    public final d<T> i(g gVar) {
        return j(gVar, false, e());
    }

    public final d<T> j(g gVar, boolean z10, int i10) {
        Objects.requireNonNull(gVar, "scheduler is null");
        ob.b.a(i10, "bufferSize");
        return vb.a.i(new rb.d(this, gVar, z10, i10));
    }

    public final <U> d<U> k(Class<U> cls) {
        Objects.requireNonNull(cls, "clazz is null");
        return g(ob.a.c(cls)).f(cls);
    }

    public final kb.b l(mb.c<? super T> cVar, mb.c<? super Throwable> cVar2) {
        return m(cVar, cVar2, ob.a.f21824c);
    }

    public final kb.b m(mb.c<? super T> cVar, mb.c<? super Throwable> cVar2, mb.a aVar) {
        Objects.requireNonNull(cVar, "onNext is null");
        Objects.requireNonNull(cVar2, "onError is null");
        Objects.requireNonNull(aVar, "onComplete is null");
        qb.c cVar3 = new qb.c(cVar, cVar2, aVar, ob.a.b());
        d(cVar3);
        return cVar3;
    }

    public abstract void n(f<? super T> fVar);
}