package defpackage;

import androidx.media3.container.NalUnitUtil;
import java.io.IOException;
import java.io.OutputStream;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0002\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Ldz6;", "Lmv8;", "okio"}, k = 1, mv = {1, 9, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
final class dz6 implements mv8 {
    public final OutputStream a;
    public final ko9 b;

    public dz6(OutputStream outputStream, ko9 ko9Var) {
        this.a = outputStream;
        this.b = ko9Var;
    }

    @Override // defpackage.mv8, java.io.Closeable, java.lang.AutoCloseable
    public final void close() throws IOException {
        this.a.close();
    }

    @Override // defpackage.mv8, java.io.Flushable
    public final void flush() throws IOException {
        this.a.flush();
    }

    @Override // defpackage.mv8
    /* JADX INFO: renamed from: timeout, reason: from getter */
    public final ko9 getB() {
        return this.b;
    }

    public final String toString() {
        return "sink(" + this.a + ')';
    }

    @Override // defpackage.mv8
    public final void write(lg0 lg0Var, long j) throws IOException {
        cr4.g(lg0Var, "source");
        C0696t.b(lg0Var.b, 0L, j);
        while (j > 0) {
            this.b.throwIfReached();
            me8 me8Var = lg0Var.a;
            cr4.d(me8Var);
            int iMin = (int) Math.min(j, me8Var.c - me8Var.b);
            this.a.write(me8Var.a, me8Var.b, iMin);
            int i = me8Var.b + iMin;
            me8Var.b = i;
            long j2 = iMin;
            j -= j2;
            lg0Var.b -= j2;
            if (i == me8Var.c) {
                lg0Var.a = me8Var.a();
                te8.a(me8Var);
            }
        }
    }
}