/* language convertion www.dsource.org/project/tioport */
module java.io.ByteArrayInputStream;

import java.io.InputStream;

public class ByteArrayInputStream : java.io.InputStream.InputStream {

    alias java.io.InputStream.InputStream.read read;
    alias java.io.InputStream.InputStream.skip skip;
    alias java.io.InputStream.InputStream.available available;
    alias java.io.InputStream.InputStream.close close;
    alias java.io.InputStream.InputStream.mark mark;
    alias java.io.InputStream.InputStream.reset reset;
    alias java.io.InputStream.InputStream.markSupported markSupported;

    protected byte[] buf;
    protected int pos;
    protected int fld_mark = 0;
    //protected int count;
    public this ( byte[] aBuf ){
        this.buf = aBuf;
    }

    public this ( byte[] aBuf, int offset, int length_ESCAPE ){
        this.buf = aBuf[ offset .. offset+length_ESCAPE ];
    }

    public int read(){
        synchronized {
            if( pos >= this.buf.length ){
                return -1;
            }
            int result = this.buf[pos];
            pos++;
            return result & 0xFF;
        }
    }

    public int read( byte[] b, int off, int len ){
        synchronized return super.read( b, off, len );
    }

    public long skip( long n ){
        synchronized {
            pos += n;
            return 0L;
        }
    }

    public int available(){
        synchronized {
            if( pos >= this.buf.length ){
                return 0;
            }
            return this.buf.length - pos;
        }
    }

    public bool markSupported(){
        return false;
    }

    public synchronized void mark( int readAheadLimit ){
    }

    public synchronized void reset(){
        pos = 0;
    }

    public void close(){
    }


}