package d.f.a.q2.e;

import com.ifpdos.debugmenu.upgrades.listener.IUpgradeListener;
import d.f.a.r2.s2;
import g.a0;
import g.h0.b.l;
import g.h0.c.m;

/* JADX INFO: compiled from: BaseUpgradeUpsTask.kt */
/* JADX INFO: loaded from: classes.dex */
@g.i
public final class e extends m implements l<s2<Float>, a0> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ IUpgradeListener f3120b;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final /* synthetic */ f f3121e;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public e(IUpgradeListener iUpgradeListener, f fVar) {
        super(1);
        this.f3120b = iUpgradeListener;
        this.f3121e = fVar;
    }

    @Override // g.h0.b.l
    public a0 invoke(s2<Float> s2Var) {
        s2<Float> s2Var2 = s2Var;
        g.h0.c.l.f(s2Var2, "$this$customSubscribe");
        s2Var2.b(new b(this.f3120b));
        s2Var2.a(new c(this.f3121e, this.f3120b));
        final d dVar = new d(this.f3120b);
        g.h0.c.l.f(dVar, "block");
        s2Var2.f3320c = new f.a.v.a() { // from class: d.f.a.r2.d
            @Override // f.a.v.a
            public final void run() {
                g.h0.b.a aVar = dVar;
                g.h0.c.l.f(aVar, "$tmp0");
                aVar.invoke();
            }
        };
        return a0.a;
    }
}