package l;

import java.io.IOException;
import java.lang.annotation.Annotation;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.concurrent.Executor;
import javax.annotation.Nullable;
import l.c;
import okhttp3.Request;

/* JADX INFO: compiled from: DefaultCallAdapterFactory.java */
/* JADX INFO: loaded from: classes.dex */
public final class k extends c.a {

    @Nullable
    public final Executor a;

    /* JADX INFO: compiled from: DefaultCallAdapterFactory.java */
    public class a implements c<Object, l.b<?>> {
        public final /* synthetic */ Type a;

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

        public a(k kVar, Type type, Executor executor) {
            this.a = type;
            this.f5038b = executor;
        }

        @Override // l.c
        public Type a() {
            return this.a;
        }

        @Override // l.c
        public l.b<?> b(l.b<Object> bVar) {
            Executor executor = this.f5038b;
            return executor == null ? bVar : new b(executor, bVar);
        }
    }

    /* JADX INFO: compiled from: DefaultCallAdapterFactory.java */
    public static final class b<T> implements l.b<T> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final Executor f5039b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final l.b<T> f5040e;

        /* JADX INFO: compiled from: DefaultCallAdapterFactory.java */
        public class a implements d<T> {
            public final /* synthetic */ d a;

            /* JADX INFO: renamed from: l.k$b$a$a, reason: collision with other inner class name */
            /* JADX INFO: compiled from: DefaultCallAdapterFactory.java */
            public class RunnableC0090a implements Runnable {

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

                public RunnableC0090a(b0 b0Var) {
                    this.f5042b = b0Var;
                }

                @Override // java.lang.Runnable
                public void run() {
                    if (b.this.f5040e.isCanceled()) {
                        a aVar = a.this;
                        aVar.a.a(b.this, new IOException("Canceled"));
                    } else {
                        a aVar2 = a.this;
                        aVar2.a.b(b.this, this.f5042b);
                    }
                }
            }

            /* JADX INFO: renamed from: l.k$b$a$b, reason: collision with other inner class name */
            /* JADX INFO: compiled from: DefaultCallAdapterFactory.java */
            public class RunnableC0091b implements Runnable {

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

                public RunnableC0091b(Throwable th) {
                    this.f5044b = th;
                }

                @Override // java.lang.Runnable
                public void run() {
                    a aVar = a.this;
                    aVar.a.a(b.this, this.f5044b);
                }
            }

            public a(d dVar) {
                this.a = dVar;
            }

            @Override // l.d
            public void a(l.b<T> bVar, Throwable th) {
                b.this.f5039b.execute(new RunnableC0091b(th));
            }

            @Override // l.d
            public void b(l.b<T> bVar, b0<T> b0Var) {
                b.this.f5039b.execute(new RunnableC0090a(b0Var));
            }
        }

        public b(Executor executor, l.b<T> bVar) {
            this.f5039b = executor;
            this.f5040e = bVar;
        }

        @Override // l.b
        public void cancel() {
            this.f5040e.cancel();
        }

        @Override // l.b
        public b0<T> execute() throws IOException {
            return this.f5040e.execute();
        }

        @Override // l.b
        public void f(d<T> dVar) {
            this.f5040e.f(new a(dVar));
        }

        @Override // l.b
        public boolean isCanceled() {
            return this.f5040e.isCanceled();
        }

        @Override // l.b
        public Request request() {
            return this.f5040e.request();
        }

        @Override // l.b
        public l.b<T> clone() {
            return new b(this.f5039b, this.f5040e.clone());
        }
    }

    public k(@Nullable Executor executor) {
        this.a = executor;
    }

    @Override // l.c.a
    @Nullable
    public c<?, ?> a(Type type, Annotation[] annotationArr, c0 c0Var) {
        if (g0.f(type) != l.b.class) {
            return null;
        }
        if (type instanceof ParameterizedType) {
            return new a(this, g0.e(0, (ParameterizedType) type), g0.i(annotationArr, e0.class) ? null : this.a);
        }
        throw new IllegalArgumentException("Call return type must be parameterized as Call<Foo> or Call<? extends Foo>");
    }
}