小红书.apk(点击下载) / b.java

package dw2;

import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
import mw2.l;
import nw2.c;
import nw2.d;
import nw2.e;
import nw2.f;
import nw2.g;
import nw2.h;
import nw2.i;
import nw2.j;
import nw2.k;
import zw2.a;

/* compiled from: Completable */
public abstract class b implements g {
    public static b g() {
        return a.k(e.f111725a);
    }

    public static b h(f fVar) {
        kw2.b.e(fVar, "source is null");
        return a.k(new nw2.b(fVar));
    }

    public static b i(Callable<? extends g> callable) {
        kw2.b.e(callable, "completableSupplier");
        return a.k(new c(callable));
    }

    public static b o(Throwable th3) {
        kw2.b.e(th3, "error is null");
        return a.k(new f(th3));
    }

    public static b p(Callable<?> callable) {
        kw2.b.e(callable, "callable is null");
        return a.k(new g(callable));
    }

    public static b q(Iterable<? extends g> iterable) {
        kw2.b.e(iterable, "sources is null");
        return a.k(new h(iterable));
    }

    public static b r() {
        return a.k(i.f111732a);
    }

    public static NullPointerException y(Throwable th3) {
        NullPointerException nullPointerException = new NullPointerException("Actually not, but can't pass out an exception otherwise...");
        nullPointerException.initCause(th3);
        return nullPointerException;
    }

    @Override // dw2.g
    public final void a(e eVar) {
        kw2.b.e(eVar, "observer is null");
        try {
            e w14 = a.w(this, eVar);
            kw2.b.e(w14, "The RxJavaPlugins.onSubscribe hook returned a null CompletableObserver. Please check the handler provided to RxJavaPlugins.setOnCompletableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
            w(w14);
        } catch (NullPointerException e14) {
            throw e14;
        } catch (Throwable th3) {
            io.reactivex.exceptions.a.b(th3);
            a.s(th3);
            throw y(th3);
        }
    }

    public final b d(g gVar) {
        kw2.b.e(gVar, "next is null");
        return a.k(new nw2.a(this, gVar));
    }

    public final <T> r<T> e(w<T> wVar) {
        kw2.b.e(wVar, "next is null");
        return a.n(new qw2.a(this, wVar));
    }

    public final <R> R f(c<? extends R> cVar) {
        return (R) ((c) kw2.b.e(cVar, "converter is null")).c(this);
    }

    public final b j(long j14, TimeUnit timeUnit) {
        return l(j14, timeUnit, cx2.a.a(), false);
    }

    public final b k(long j14, TimeUnit timeUnit, z zVar) {
        return l(j14, timeUnit, zVar, false);
    }

    public final b l(long j14, TimeUnit timeUnit, z zVar, boolean z14) {
        kw2.b.e(timeUnit, "unit is null");
        kw2.b.e(zVar, "scheduler is null");
        return a.k(new d(this, j14, timeUnit, zVar, z14));
    }

    public final b m(iw2.g<? super Throwable> gVar) {
        iw2.g<? super hw2.c> f14 = kw2.a.f();
        iw2.a aVar = kw2.a.f99616c;
        return n(f14, gVar, aVar, aVar, aVar, aVar);
    }

    public final b n(iw2.g<? super hw2.c> gVar, iw2.g<? super Throwable> gVar2, iw2.a aVar, iw2.a aVar2, iw2.a aVar3, iw2.a aVar4) {
        kw2.b.e(gVar, "onSubscribe is null");
        kw2.b.e(gVar2, "onError is null");
        kw2.b.e(aVar, "onComplete is null");
        kw2.b.e(aVar2, "onTerminate is null");
        kw2.b.e(aVar3, "onAfterTerminate is null");
        kw2.b.e(aVar4, "onDispose is null");
        return a.k(new k(this, gVar, gVar2, aVar, aVar2, aVar3, aVar4));
    }

    public final b s(z zVar) {
        kw2.b.e(zVar, "scheduler is null");
        return a.k(new j(this, zVar));
    }

    public final hw2.c t() {
        l lVar = new l();
        a(lVar);
        return lVar;
    }

    public final hw2.c u(iw2.a aVar) {
        kw2.b.e(aVar, "onComplete is null");
        mw2.h hVar = new mw2.h(aVar);
        a(hVar);
        return hVar;
    }

    public final hw2.c v(iw2.a aVar, iw2.g<? super Throwable> gVar) {
        kw2.b.e(gVar, "onError is null");
        kw2.b.e(aVar, "onComplete is null");
        mw2.h hVar = new mw2.h(gVar, aVar);
        a(hVar);
        return hVar;
    }

    public abstract void w(e eVar);

    public final b x(z zVar) {
        kw2.b.e(zVar, "scheduler is null");
        return a.k(new nw2.l(this, zVar));
    }
}