Tuesday, January 10, 2012

Decompressing input stream

package com.nmmc.dms.utils.compression;

import java.io.IOException;
import java.io.InputStream;
import java.util.zip.Inflater;
import java.util.zip.InflaterInputStream;

public class DecompressingInputStream extends InflaterInputStream {

    public DecompressingInputStream(final InputStream in) {
        super(in, new Inflater(true),4*1024);
    }

    public int available() throws IOException {
        if (!inf.finished() && !inf.needsInput()) {
            return 1;
        } else {
            return in.available();
        }
    }

}