Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 //  The contents of this file are subject to the Mozilla Public License
 //  Version 1.1 (the "License"); you may not use this file except in
 //  compliance with the License. You may obtain a copy of the License
 //  at http://www.mozilla.org/MPL/
 //
 //  Software distributed under the License is distributed on an "AS IS"
 //  basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
 //  the License for the specific language governing rights and
 //  limitations under the License.
//
//  The Original Code is RabbitMQ.
//
//  The Initial Developer of the Original Code is VMware, Inc.
//  Copyright (c) 2007-2012 VMware, Inc.  All rights reserved.
//
package com.rabbitmq.client.impl;
Utility stream: proxies another stream, making it appear to be no longer than a preset limit.
public class TruncatedInputStream extends FilterInputStream {
    private final long limit;
    private long counter = 0L;
    private long mark = 0L;
    public TruncatedInputStream(InputStream inlong limit) {
        super(in);
        this. = limit;
    }
    @Override public int available() throws IOException {
        return (int) Math.min( - super.available());
    }
    @Override public void mark(int readlimit) {
        super.mark(readlimit);
         = ;
    }
    @Override public int read() throws IOException {
        if ( < ) {
            int result = super.read();
            if (result >= 0)
                ++;
            return result;
        }
            return -1;
    }
    @Override public int read(byte[] bint offint lenthrows IOException {
        if ( > ) {
            int result = super.read(b, off, (int) Math.min(len, limit - ));
            if (result > 0)
                 += result;
            return result;
        }
            return -1;
    }
    @Override public void reset() throws IOException {
        super.reset();
         = ;
    }
    @Override public long skip(long nthrows IOException {
        long result = super.skip(Math.min(n, limit - ));
         += result;
        return result;
    }
New to GrepCode? Check out our FAQ X