package j;

import j.c;
import java.io.IOException;
import java.lang.annotation.Annotation;
import java.lang.reflect.Type;
import java.util.concurrent.Executor;

/* JADX INFO: compiled from: ExecutorCallAdapterFactory.java */
/* JADX INFO: loaded from: classes.dex */
final class g extends c.a {
    final Executor a;

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

        a(Type type) {
            this.a = type;
        }

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

        @Override // j.c
        /* JADX INFO: renamed from: c, reason: merged with bridge method [inline-methods] */
        public j.b<Object> b(j.b<Object> bVar) {
            return new b(g.this.a, bVar);
        }
    }

    /* JADX INFO: compiled from: ExecutorCallAdapterFactory.java */
    static final class b<T> implements j.b<T> {

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        final j.b<T> f4324f;

        /* JADX INFO: compiled from: ExecutorCallAdapterFactory.java */
        class a implements d<T> {

            /* JADX INFO: renamed from: b, reason: collision with root package name */
            final /* synthetic */ d f4325b;

            /* JADX INFO: renamed from: j.g$b$a$a, reason: collision with other inner class name */
            /* JADX INFO: compiled from: ExecutorCallAdapterFactory.java */
            class RunnableC0135a implements Runnable {

                /* JADX INFO: renamed from: b, reason: collision with root package name */
                final /* synthetic */ m f4327b;

                RunnableC0135a(m mVar) {
                    this.f4327b = mVar;
                }

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

            /* JADX INFO: renamed from: j.g$b$a$b, reason: collision with other inner class name */
            /* JADX INFO: compiled from: ExecutorCallAdapterFactory.java */
            class RunnableC0136b implements Runnable {

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

                RunnableC0136b(Throwable th) {
                    this.f4329b = th;
                }

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

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

            @Override // j.d
            public void a(j.b<T> bVar, m<T> mVar) {
                b.this.f4323b.execute(new RunnableC0135a(mVar));
            }

            @Override // j.d
            public void b(j.b<T> bVar, Throwable th) {
                b.this.f4323b.execute(new RunnableC0136b(th));
            }
        }

        b(Executor executor, j.b<T> bVar) {
            this.f4323b = executor;
            this.f4324f = bVar;
        }

        @Override // j.b
        public void cancel() {
            this.f4324f.cancel();
        }

        @Override // j.b
        public void d(d<T> dVar) {
            p.b(dVar, "callback == null");
            this.f4324f.d(new a(dVar));
        }

        @Override // j.b
        public m<T> execute() throws IOException {
            return this.f4324f.execute();
        }

        @Override // j.b
        public boolean isCanceled() {
            return this.f4324f.isCanceled();
        }

        @Override // j.b
        /* JADX INFO: renamed from: clone, reason: merged with bridge method [inline-methods] */
        public j.b<T> m5clone() {
            return new b(this.f4323b, this.f4324f.m5clone());
        }
    }

    g(Executor executor) {
        this.a = executor;
    }

    @Override // j.c.a
    public c<?, ?> a(Type type, Annotation[] annotationArr, n nVar) {
        if (c.a.c(type) != j.b.class) {
            return null;
        }
        return new a(p.g(type));
    }
}