public NotifyingBufferedInputStream(InputStream is,
    int size,
    int chunkSize,
    StreamListener listener) 
{
                                                      
      super(is, size);
      if (chunkSize < = size)
         throw new IllegalArgumentException("chunkSize must be bigger than the buffer");
      this.chunkSize = chunkSize;
      this.listener = listener;
}

Construct a notifying buffered inputstream. The listener is notified once every chunk.

Parameters:

is - the input stream to be buffered

size - the buffer size

chunkSize - the chunk size

listener - the listener to notify

Throws:

IllegalArgumentException - for a size <= 0 or chunkSize <= size

exception: IllegalArgumentException - for a size <= 0 or chunkSize <= size

 public  void checkNotification(int result) 
{
      // Is a notification required?
      chunk += result;
      if (chunk  >= chunkSize)
      {
         if (listener != null)
            listener.onStreamNotification(this, chunk);
         // Start a new chunk
         chunk = 0;
      }
}

Checks whether a notification is required and notifies as appropriate

 public int read() throws IOException 
{
      int result = super.read();
      if (result == -1)
         return result;
      checkNotification(result);
      return result;
}

 public int read(byte[] b,
    int off,
    int len) throws IOException 
{
      int result = super.read(b, off, len);
      if (result == -1)
         return result;
      checkNotification(result);
      return result;
}

 public  void setStreamListener(StreamListener listener) 
{
      this.listener = listener;
}