package a0;

import b0.AbstractC0399d;
import java.io.InputStream;

/* JADX INFO: loaded from: classes.dex */
public final class g extends InputStream {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private final f f1935b;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private final h f1936g;

    /* JADX INFO: renamed from: x, reason: collision with root package name */
    private boolean f1938x = false;

    /* JADX INFO: renamed from: y, reason: collision with root package name */
    private boolean f1939y = false;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    private final byte[] f1937r = new byte[1];

    public g(f fVar, h hVar) {
        this.f1935b = fVar;
        this.f1936g = hVar;
    }

    private void a() {
        if (this.f1938x) {
            return;
        }
        this.f1935b.a(this.f1936g);
        this.f1938x = true;
    }

    public void b() {
        a();
    }

    @Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        if (this.f1939y) {
            return;
        }
        this.f1935b.close();
        this.f1939y = true;
    }

    @Override // java.io.InputStream
    public int read() {
        if (read(this.f1937r) == -1) {
            return -1;
        }
        return this.f1937r[0] & 255;
    }

    @Override // java.io.InputStream
    public long skip(long j2) {
        AbstractC0399d.e(!this.f1939y);
        a();
        return super.skip(j2);
    }

    @Override // java.io.InputStream
    public int read(byte[] bArr) {
        return read(bArr, 0, bArr.length);
    }

    @Override // java.io.InputStream
    public int read(byte[] bArr, int i2, int i3) {
        AbstractC0399d.e(!this.f1939y);
        a();
        return this.f1935b.read(bArr, i2, i3);
    }
}