Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.fasterxml.clustermate.service.util;
 
 import java.io.*;
 
 public class StatsCollectingInputStream extends InputStream
 {
     protected final InputStream _in;
     
     protected long _bytesRead;
    protected boolean _closed;
    
         = in;
    }
    public long getBytesRead() {
        return ;
    }
    @Override
    public int available() throws IOException {
        if () {
            return 0;
        }
        return .available();
    }
    
    @Override
    public void close() throws IOException {
         = true;
        .close();
    }
    
    @Override
    public boolean markSupported() { return false; }
    
    @Override
    public int read() throws IOException {
        _checkClosed();
        int c = .read();
        if (c >= 0) {
            ++;
        }
        return c;
    }
    @Override
    public int read(byte[] bthrows IOException {
        _checkClosed();
        int count = .read(b);
        if (count > 0) {
             += count;
        }
        return count;
    }
    @Override
    public int read(byte[] bint offint lenthrows IOException {
        _checkClosed();
        int count = .read(bofflen);
        if (count > 0) {
             += count;
        }
        return count;
    }
    @Override
    public long skip(long nthrows IOException {
        _checkClosed();
        long count = .skip(n);
        if (count > 0L) {
             += count;
        }
        return count;
    }
    private final void _checkClosed() throws IOException {
        if () {
            throw new IOException("Can not read from "+getClass().getName()+" after close() ("
                    ++" bytes read)");
        }
    }
New to GrepCode? Check out our FAQ X