OLX India v19.42.007 - d.java 源代码

package io.ktor.client.engine.okhttp;

import io.ktor.client.plugins.w;
import io.ktor.util.n;
import java.net.Proxy;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import kotlin.Lazy;
import kotlin.LazyKt__LazyJVMKt;
import kotlin.ResultKt;
import kotlin.Unit;
import kotlin.collections.z;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.CoroutineContext;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.FunctionReferenceImpl;
import kotlin.jvm.internal.Lambda;
import kotlinx.coroutines.o0;
import kotlinx.coroutines.q0;
import kotlinx.coroutines.q1;
import kotlinx.coroutines.x1;
import okhttp3.Dispatcher;
import okhttp3.OkHttpClient;
import okhttp3.Response;
import okhttp3.ResponseBody;

public final class d extends io.ktor.client.engine.c {
    private static final c j = new c(null);
    private static final Lazy k;
    private final io.ktor.client.engine.okhttp.c e;
    private final Set f;
    private final CoroutineContext g;
    private final CoroutineContext h;
    private final Map i;

    static final class a extends SuspendLambda implements Function2 {
        int a;

        a(Continuation continuation) {
            super(2, continuation);
        }

        @Override
        public final Continuation create(Object obj, Continuation continuation) {
            return d.this.new a(continuation);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            Object g;
            Iterator it;
            g = kotlin.coroutines.intrinsics.a.g();
            int i = this.a;
            try {
                if (i == 0) {
                    ResultKt.b(obj);
                    x1 x1Var = d.this.g.get(x1.j4);
                    this.a = 1;
                    if (x1Var.P0(this) == g) {
                        return g;
                    }
                } else {
                    if (i != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    ResultKt.b(obj);
                }
                while (it.hasNext()) {
                    OkHttpClient okHttpClient = (OkHttpClient) ((Map.Entry) it.next()).getValue();
                    okHttpClient.connectionPool().evictAll();
                    okHttpClient.dispatcher().executorService().shutdown();
                }
                return Unit.a;
            } finally {
                it = d.this.i.entrySet().iterator();
                while (it.hasNext()) {
                    OkHttpClient okHttpClient2 = (OkHttpClient) ((Map.Entry) it.next()).getValue();
                    okHttpClient2.connectionPool().evictAll();
                    okHttpClient2.dispatcher().executorService().shutdown();
                }
            }
        }

        @Override
        public final Object invoke(o0 o0Var, Continuation continuation) {
            return ((a) create(o0Var, continuation)).invokeSuspend(Unit.a);
        }
    }

    static final class b extends Lambda implements Function0 {
        public static final b d = new b();

        b() {
            super(0);
        }

        @Override
        public final OkHttpClient invoke() {
            return new OkHttpClient.Builder().build();
        }
    }

    private static final class c {
        public c(DefaultConstructorMarker defaultConstructorMarker) {
            this();
        }

        public final OkHttpClient a() {
            return (OkHttpClient) d.k.getValue();
        }

        private c() {
        }
    }

    class C0161d extends FunctionReferenceImpl implements Function1 {
        C0161d(Object obj) {
            super(1, obj, d.class, "createOkHttpClient", "createOkHttpClient(Lio/ktor/client/plugins/HttpTimeout$HttpTimeoutCapabilityConfiguration;)Lokhttp3/OkHttpClient;", 0);
        }

        @Override
        public final OkHttpClient invoke(w.a aVar) {
            return ((d) this.receiver).F(aVar);
        }
    }

    static final class e extends Lambda implements Function1 {
        public static final e d = new e();

        e() {
            super(1);
        }

        public final void a(OkHttpClient okHttpClient) {
        }

        @Override
        public Object invoke(Object obj) {
            a((OkHttpClient) obj);
            return Unit.a;
        }
    }

    static final class f extends ContinuationImpl {
        Object a;
        Object b;
        Object c;
        int e;

        f(Continuation continuation) {
            super(continuation);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            this.c = obj;
            this.e |= Integer.MIN_VALUE;
            return d.this.a1(null, this);
        }
    }

    static final class g extends ContinuationImpl {
        Object a;
        Object b;
        Object c;
        Object d;
        Object e;
        int g;

        g(Continuation continuation) {
            super(continuation);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            this.e = obj;
            this.g |= Integer.MIN_VALUE;
            return d.this.G(null, null, null, null, this);
        }
    }

    static final class h extends Lambda implements Function1 {
        final ResponseBody d;

        h(ResponseBody responseBody) {
            super(1);
            this.d = responseBody;
        }

        @Override
        public Object invoke(Object obj) {
            invoke((Throwable) obj);
            return Unit.a;
        }

        public final void invoke(Throwable th) {
            ResponseBody responseBody = this.d;
            if (responseBody != null) {
                responseBody.close();
            }
        }
    }

    static final class i extends ContinuationImpl {
        Object a;
        Object b;
        Object c;
        Object d;
        Object e;
        int g;

        i(Continuation continuation) {
            super(continuation);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            this.e = obj;
            this.g |= Integer.MIN_VALUE;
            return d.this.L(null, null, null, this);
        }
    }

    static {
        Lazy b2;
        b2 = LazyKt__LazyJVMKt.b(b.d);
        k = b2;
    }

    public d(io.ktor.client.engine.okhttp.c cVar) {
        super("ktor-okhttp");
        Set j2;
        this.e = cVar;
        j2 = z.j(w.d, io.ktor.client.plugins.websocket.a.a);
        this.f = j2;
        this.i = io.ktor.util.g.a(new C0161d(this), e.d, g().b());
        CoroutineContext a2 = n.a(super.getCoroutineContext().get(x1.j4));
        this.g = a2;
        this.h = super.getCoroutineContext().plus(a2);
        kotlinx.coroutines.i.c(q1.a, super.getCoroutineContext(), q0.ATOMIC, new a(null));
    }

    private final io.ktor.client.request.g C(Response response, io.ktor.util.date.b bVar, Object obj, CoroutineContext coroutineContext) {
        return new io.ktor.client.request.g(new io.ktor.http.w(response.code(), response.message()), bVar, io.ktor.client.engine.okhttp.h.c(response.headers()), io.ktor.client.engine.okhttp.h.d(response.protocol()), obj, coroutineContext);
    }

    public final OkHttpClient F(w.a aVar) {
        OkHttpClient d = g().d();
        if (d == null) {
            d = j.a();
        }
        OkHttpClient.Builder newBuilder = d.newBuilder();
        newBuilder.dispatcher(new Dispatcher());
        g().c().invoke(newBuilder);
        Proxy a2 = g().a();
        if (a2 != null) {
            newBuilder.proxy(a2);
        }
        if (aVar != null) {
            io.ktor.client.engine.okhttp.e.h(newBuilder, aVar);
        }
        return newBuilder.build();
    }

    public final java.lang.Object G(okhttp3.OkHttpClient r6, okhttp3.Request r7, kotlin.coroutines.CoroutineContext r8, io.ktor.client.request.d r9, kotlin.coroutines.Continuation r10) {
        throw new UnsupportedOperationException("Method not decompiled: io.ktor.client.engine.okhttp.d.G(okhttp3.OkHttpClient, okhttp3.Request, kotlin.coroutines.CoroutineContext, io.ktor.client.request.d, kotlin.coroutines.Continuation):java.lang.Object");
    }

    public final java.lang.Object L(okhttp3.OkHttpClient r6, okhttp3.Request r7, kotlin.coroutines.CoroutineContext r8, kotlin.coroutines.Continuation r9) {
        throw new UnsupportedOperationException("Method not decompiled: io.ktor.client.engine.okhttp.d.L(okhttp3.OkHttpClient, okhttp3.Request, kotlin.coroutines.CoroutineContext, kotlin.coroutines.Continuation):java.lang.Object");
    }

    @Override
    public Set R() {
        return this.f;
    }

    @Override
    public io.ktor.client.engine.okhttp.c g() {
        return this.e;
    }

    @Override
    public java.lang.Object a1(io.ktor.client.request.d r10, kotlin.coroutines.Continuation r11) {
        throw new UnsupportedOperationException("Method not decompiled: io.ktor.client.engine.okhttp.d.a1(io.ktor.client.request.d, kotlin.coroutines.Continuation):java.lang.Object");
    }

    @Override
    public void close() {
        super.close();
        this.g.get(x1.j4).b();
    }

    @Override
    public CoroutineContext getCoroutineContext() {
        return this.h;
    }
}