monitoredoutputstream.java

来自「前期开发时开发的新闻发布系统」· Java 代码 · 共 45 行

package book.upload;

import java.io.OutputStream;
import java.io.IOException;

public class MonitoredOutputStream extends OutputStream 
{
	
	private OutputStream target;
	private OutputStreamListener listener;

	public MonitoredOutputStream(OutputStream target, OutputStreamListener listener) 
	{		
		this.target = target;
		this.listener = listener;
	}

	public void write(byte b[], int off, int len) throws IOException 
	{	
		target.write(b, off, len);
		listener.bytesRead(len - off);
	}

	public void write(byte b[]) throws IOException 
	{		
		target.write(b);
		listener.bytesRead(b.length);
	}

	public void write(int b) throws IOException 
	{		
		target.write(b);
		listener.bytesRead(1);
	}

	public void close() throws IOException 
	{		
		target.close();
	}

	public void flush() throws IOException 
	{		
		target.flush();
	}
}