view src/goodjava/io/FixedLengthInputStream.java @ 1493:471ef3e6a84e

more io
author Franklin Schmidt <fschmidt@gmail.com>
date Sun, 03 May 2020 00:12:15 -0600
parents 9a2a2181a58f
children 91c167099462
line wrap: on
line source

package goodjava.io;

import java.io.InputStream;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.EOFException;


public class FixedLengthInputStream extends FilterInputStream {
	protected long left;

	public FixedLengthInputStream(InputStream in, long len) {
		super(in);
		if( len < 0 )
			throw new IllegalArgumentException("len can't be negative");
		this.left = len;
	}

	public synchronized int read() throws IOException {
		if( left == 0 )
			return -1;
		int n = super.read();
		if( n == -1 )
			throw new EOFException();
		left--;
		return n;
	}

	public synchronized int read(byte[] b, int off, int len) throws IOException {
		if( len == 0 )
			return 0;
		if( left == 0 )
			return -1;
		if( len > left )
			len = (int)left;
		int n = super.read(b,off,len);
		if( n == -1 )
			throw new EOFException();
		left -= n;
		return n;
	}

	public synchronized long skip(long n) throws IOException {
		if( n > left )
			n = left;
		n = in.skip(n);
		left -= n;
		return n;
	}

	public synchronized int available() throws IOException {
		int n = in.available();
		if( n > left )
			n = (int)left;
		return n;
	}

	public void mark(int readlimit) {}

	public void reset() throws IOException {
		throw new IOException("not supported");
	}

	public boolean markSupported() {
		return false;
	}

}