Package net.i2p.util

Class ResettableGZIPInputStream

java.lang.Object
java.io.InputStream
java.io.FilterInputStream
java.util.zip.InflaterInputStream
net.i2p.util.ResettableGZIPInputStream
All Implemented Interfaces:
Closeable, AutoCloseable
Direct Known Subclasses:
ReusableGZIPInputStream
public class ResettableGZIPInputStream extends InflaterInputStream
GZIP implementation per RFC 1952, reusing java's standard CRC32 and Inflater and InflaterInputStream implementations. The main difference is that this implementation allows its state to be reset to initial values, and hence reused, while the standard GZIPInputStream reads the GZIP header from the stream on instantiation.

  • Constructor Details

    • ResettableGZIPInputStream

      public ResettableGZIPInputStream()
      Build a new GZIP stream without a bound compressed stream. You need to initialize this with initialize(compressedStream) when you want to decompress a stream.

    • ResettableGZIPInputStream

      public ResettableGZIPInputStream(InputStream compressedStream) throws IOException
      Warning - blocking!
      Throws:
      IOException

  • Method Details

    • initialize

      public void initialize(InputStream compressedStream) throws IOException
      Blocking call to initialize this stream with the data from the given compressed stream.
      Throws:
      IOException

    • read

      public int read() throws IOException
      Overrides:
      read in class InflaterInputStream
      Throws:
      IOException

    • read

      public int read(byte[] buf) throws IOException
      Overrides:
      read in class FilterInputStream
      Throws:
      IOException

    • read

      public int read(byte[] buf, int off, int len) throws IOException
      Overrides:
      read in class InflaterInputStream
      Throws:
      IOException

    • getTotalRead

      public long getTotalRead()
      Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream
      Since:
      0.8.9

    • getTotalExpanded

      public long getTotalExpanded()
      Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream
      Since:
      0.8.9

    • getRemaining

      public long getRemaining()
      Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream
      Since:
      0.8.9

    • getFinished

      public boolean getFinished()
      Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream
      Since:
      0.8.9

    • destroy

      public void destroy() throws IOException
      Calls super.close(). May not be reused after this.
      Throws:
      IOException
      Since:
      0.9.40

    • close

      public void close() throws IOException
      Does NOT call super.close(), as it cannot be reused if we do that. Broken before 0.9.20.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Overrides:
      close in class InflaterInputStream
      Throws:
      IOException
      Since:
      0.9.20

    • toString

      public String toString()
      Moved from i2ptunnel HTTPResponseOutputStream.InternalGZIPInputStream
      Overrides:
      toString in class Object
      Since:
      0.8.9