漫天星 v3.0.2 - b.java 源代码

package f.p.g;

import android.content.Context;
import com.junyue.repository.bean.AppConfig;
import com.junyue.repository.bean.OSSUrlBean;
import f.p.c.d.e;
import i.b0.c.u;
import i.t;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;
import kotlin.jvm.functions.Function0;
import n.a0.f;
import n.a0.r;

public final class b implements e {

    public interface a {
        @f("static/config/{appid}.json")
        Observable<OSSUrlBean> a(@r("appid") String str);
    }

    public static final class C0094b extends u implements Function0<t> {
        public final Function0 n;

        public C0094b(Function0 function0) {
            super(0);
            this.n = function0;
        }

        public Object invoke() {
            m80invoke();
            return t.a;
        }

        public final void m80invoke() {
            this.n.invoke();
        }
    }

    public static final class c implements Observer<OSSUrlBean> {
        public final Function0 o;

        public c(Function0 function0) {
            this.o = function0;
        }

        @Override
        public void onNext(OSSUrlBean oSSUrlBean) {
            if (oSSUrlBean != null) {
                OSSUrlBean.Companion.d(oSSUrlBean);
            }
            b.this.h(this.o);
        }

        @Override
        public void onComplete() {
        }

        @Override
        public void onError(Throwable th) {
            this.o.invoke();
            b.this.h(this.o);
        }

        @Override
        public void onSubscribe(Disposable disposable) {
            i.b0.c.t.e(disposable, "d");
        }
    }

    @Override
    public boolean d() {
        return true;
    }

    @Override
    public void f(Context context, Function0<Void> function0) {
        i.b0.c.t.e(context, "context");
        i.b0.c.t.e(function0, "callback");
        if (f.p.c.s.b.j()) {
            ((a) f.p.d.b.a.a("http://manhua20230225.oss-cn-shanghai.aliyuncs.com/").b(a.class)).a("19").subscribe(new c(function0));
        } else {
            function0.invoke();
        }
    }

    public final void h(Function0<Void> function0) {
        AppConfig.u(new C0094b(function0), true);
    }
}