package defpackage;

import defpackage.ca;
import defpackage.g2;
import defpackage.oi4;
import defpackage.p96;
import defpackage.z61;
import java.util.Objects;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.Future;

/* JADX INFO: loaded from: classes2.dex */
@az3
@ii2
public final class ks3 extends cz3 {

    public static final class a<V> implements Runnable {
        public final Future a;
        public final ds3 b;

        public a(zb5 zb5Var, ds3 ds3Var) {
            this.a = zb5Var;
            this.b = ds3Var;
        }

        /* JADX WARN: Multi-variable type inference failed */
        @Override // java.lang.Runnable
        public final void run() {
            Throwable thTryInternalFastPathGetFailure;
            Future future = this.a;
            boolean z = future instanceof jq4;
            ds3 ds3Var = this.b;
            if (z && (thTryInternalFastPathGetFailure = ((jq4) future).tryInternalFastPathGetFailure()) != null) {
                ds3Var.onFailure(thTryInternalFastPathGetFailure);
                return;
            }
            try {
                ds3Var.onSuccess(ks3.b(future));
            } catch (ExecutionException e) {
                ds3Var.onFailure(e.getCause());
            } catch (Throwable th) {
                ds3Var.onFailure(th);
            }
        }

        public final String toString() {
            p96.b bVarB = p96.b(this);
            bVarB.c(this.b);
            return bVarB.toString();
        }
    }

    @az3
    public static final class b<V> {
        public final bj4 a;

        public b(bj4 bj4Var) {
            this.a = bj4Var;
        }

        public final void a(tb5 tb5Var) {
            ls3 ls3Var = new ls3(tb5Var);
            bj4 bj4Var = this.a;
            int size = bj4Var.size();
            z61 z61Var = new z61();
            Object obj = null;
            z61Var.a = null;
            z61Var.b = size;
            z61Var.e = bj4Var;
            z61Var.i = new z61.b(ls3Var);
            za2 za2Var = za2.a;
            Objects.requireNonNull(z61Var.e);
            if (z61Var.e.isEmpty()) {
                z61Var.i();
                return;
            }
            yg ygVar = new yg(z61Var, obj, 0);
            p7a it = z61Var.e.iterator();
            while (it.hasNext()) {
                zb5 zb5Var = (zb5) it.next();
                if (zb5Var.isDone()) {
                    z61Var.h(null);
                } else {
                    zb5Var.addListener(ygVar, za2Var);
                }
            }
        }
    }

    public static final class c<T> extends ca<T> {
        @Override // defpackage.ca
        public final void afterDone() {
        }

        @Override // defpackage.ca, java.util.concurrent.Future
        public final boolean cancel(boolean z) {
            if (super.cancel(z)) {
                throw null;
            }
            return false;
        }

        @Override // defpackage.ca
        public final String pendingToString() {
            return null;
        }
    }

    public static final class d<T> {
    }

    public static final class e<V> extends ca.j<V> implements Runnable {
        @Override // defpackage.ca
        public final void afterDone() {
        }

        @Override // defpackage.ca
        public final String pendingToString() {
            return null;
        }

        @Override // java.lang.Runnable
        public final void run() {
        }
    }

    public static void a(zb5 zb5Var, ds3 ds3Var, Executor executor) {
        ds3Var.getClass();
        zb5Var.addListener(new a(zb5Var, ds3Var), executor);
    }

    public static Object b(Future future) {
        if7.q(future.isDone(), "Future was expected to be done: %s", future);
        return b6a.a(future);
    }

    public static zb5 c(Throwable th) {
        oi4.b bVar = new oi4.b();
        bVar.setException(th);
        return bVar;
    }

    public static zb5 d(Object obj) {
        return obj == null ? oi4.b : new oi4(obj);
    }

    public static zb5 e() {
        return oi4.b;
    }

    public static zb5 f(zb5 zb5Var, jr3 jr3Var) {
        int i = g2.c;
        g2.b bVar = new g2.b();
        zb5Var.getClass();
        bVar.a = zb5Var;
        bVar.b = jr3Var;
        zb5Var.addListener(bVar, za2.a);
        return bVar;
    }
}