package okhttp3.sse;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import com.google.android.gms.common.internal.ServiceSpecificExtraArgs;
import defpackage.cr4;
import defpackage.dj1;
import defpackage.kp6;
import defpackage.x15;
import kotlin.Metadata;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.internal.sse.RealEventSource;
import okhttp3.sse.EventSource;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000.\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\bÆ\u0002\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003J\u0017\u0010\u0007\u001a\u00020\u00062\u0006\u0010\u0005\u001a\u00020\u0004H\u0007¢\u0006\u0004\b\u0007\u0010\bJ\u001f\u0010\u000e\u001a\u00020\r2\u0006\u0010\n\u001a\u00020\t2\u0006\u0010\f\u001a\u00020\u000bH\u0007¢\u0006\u0004\b\u000e\u0010\u000f¨\u0006\u0010"}, d2 = {"Lokhttp3/sse/EventSources;", "", "<init>", "()V", "Lokhttp3/OkHttpClient;", "client", "Lokhttp3/sse/EventSource$Factory;", "createFactory", "(Lokhttp3/OkHttpClient;)Lokhttp3/sse/EventSource$Factory;", "Lokhttp3/Response;", "response", "Lokhttp3/sse/EventSourceListener;", ServiceSpecificExtraArgs.CastExtraArgs.LISTENER, "Le6a;", "processResponse", "(Lokhttp3/Response;Lokhttp3/sse/EventSourceListener;)V", "okhttp-sse"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class EventSources {

    @kp6
    public static final EventSources INSTANCE = new EventSources();

    private EventSources() {
    }

    @x15
    @kp6
    public static final EventSource.Factory createFactory(@kp6 OkHttpClient client) {
        cr4.g(client, "client");
        return new dj1(client, 23);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final EventSource createFactory$lambda$1(OkHttpClient okHttpClient, Request request, EventSourceListener eventSourceListener) {
        cr4.g(okHttpClient, "$client");
        cr4.g(request, "request");
        cr4.g(eventSourceListener, ServiceSpecificExtraArgs.CastExtraArgs.LISTENER);
        if (request.header(RtspHeaders.ACCEPT) == null) {
            request = request.newBuilder().addHeader(RtspHeaders.ACCEPT, "text/event-stream").build();
        }
        RealEventSource realEventSource = new RealEventSource(request, eventSourceListener);
        realEventSource.connect(okHttpClient);
        return realEventSource;
    }

    @x15
    public static final void processResponse(@kp6 Response response, @kp6 EventSourceListener listener) {
        cr4.g(response, "response");
        cr4.g(listener, ServiceSpecificExtraArgs.CastExtraArgs.LISTENER);
        new RealEventSource(response.request(), listener).processResponse(response);
    }
}