monitoredoutputstream.java

一个视频网站的源码

package com.puckasoft.video312.upload;

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

public class MonitoredOutputStream extends OutputStream
{
  private OutputStream outputStream;
  private OutputStreamListener outputStreamListener;

  public MonitoredOutputStream(OutputStream outputStream, OutputStreamListener outputStreamListener)
  {
    this.outputStream = outputStream;
    this.outputStreamListener = outputStreamListener;
    this.outputStreamListener.start();
  }

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

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

  public void write(int b) throws IOException
  {
    outputStream.write(b);
    outputStreamListener.bytesRead(1);
  }

  public void close() throws IOException
  {
    outputStream.close();
    outputStreamListener.done();
  }

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