package defpackage;

import android.os.Handler;
import android.os.HandlerThread;
import j$.util.Objects;
import java.io.Closeable;
import java.io.OutputStream;

/* JADX INFO: renamed from: ᵟᵚˇ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C3089 implements Closeable {

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final OutputStream f11780;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final Handler f11781;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final HandlerThread f11782;

    public C3089(C5094 c5094, OutputStream outputStream) {
        this.f11780 = outputStream;
        HandlerThread handlerThread = new HandlerThread("ExoPlayer:RtspMessageChannel:Sender");
        this.f11782 = handlerThread;
        handlerThread.start();
        this.f11781 = new Handler(handlerThread.getLooper());
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        HandlerThread handlerThread = this.f11782;
        Objects.requireNonNull(handlerThread);
        this.f11781.post(new RunnableC4972(11, handlerThread));
        try {
            handlerThread.join();
        } catch (InterruptedException unused) {
            handlerThread.interrupt();
        }
    }
}