package defpackage;

import defpackage.bg3;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;

/* JADX INFO: loaded from: classes2.dex */
@az3
@ii2
abstract class g2<I, O, F, T> extends bg3.a<O> implements Runnable {
    public static final /* synthetic */ int c = 0;
    public zb5 a;
    public jr3 b;

    public static final class a<I, O> extends g2<I, O, qv<? super I, ? extends O>, zb5<? extends O>> {
        @Override // defpackage.g2
        public final Object h(jr3 jr3Var, Object obj) {
            qv qvVar = (qv) jr3Var;
            zb5 zb5VarApply = qvVar.apply(obj);
            if (zb5VarApply != null) {
                return zb5VarApply;
            }
            throw new NullPointerException(m89.a("AsyncFunction.apply returned null instead of a Future. Did you mean to return immediateFuture(null)? %s", qvVar));
        }

        @Override // defpackage.g2
        public final void i(Object obj) {
            setFuture((zb5) obj);
        }
    }

    public static final class b<I, O> extends g2<I, O, jr3<? super I, ? extends O>, O> {
        @Override // defpackage.g2
        public final Object h(jr3 jr3Var, Object obj) {
            return jr3Var.apply(obj);
        }

        @Override // defpackage.g2
        public final void i(Object obj) {
            set(obj);
        }
    }

    @Override // defpackage.ca
    public final void afterDone() {
        maybePropagateCancellationTo(this.a);
        this.a = null;
        this.b = null;
    }

    public abstract Object h(jr3 jr3Var, Object obj);

    public abstract void i(Object obj);

    @Override // defpackage.ca
    public final String pendingToString() {
        String str;
        zb5 zb5Var = this.a;
        jr3 jr3Var = this.b;
        String strPendingToString = super.pendingToString();
        if (zb5Var != null) {
            str = "inputFuture=[" + zb5Var + "], ";
        } else {
            str = "";
        }
        if (jr3Var == null) {
            if (strPendingToString != null) {
                return vw2.k(str, strPendingToString);
            }
            return null;
        }
        return str + "function=[" + jr3Var + "]";
    }

    @Override // java.lang.Runnable
    public final void run() {
        zb5<? extends V> zb5Var = this.a;
        jr3 jr3Var = this.b;
        if ((isCancelled() | (zb5Var == 0)) || (jr3Var == null)) {
            return;
        }
        this.a = null;
        if (zb5Var.isCancelled()) {
            setFuture(zb5Var);
            return;
        }
        try {
            try {
                Object objH = h(jr3Var, ks3.b(zb5Var));
                this.b = null;
                i(objH);
            } catch (Throwable th) {
                try {
                    c87.a(th);
                    setException(th);
                } finally {
                    this.b = null;
                }
            }
        } catch (Error e) {
            setException(e);
        } catch (CancellationException unused) {
            cancel(false);
        } catch (ExecutionException e2) {
            setException(e2.getCause());
        } catch (Exception e3) {
            setException(e3);
        }
    }
}