public CompressionInputStream createInputStream()

in src/main/java/com/hadoop/compression/lzo/LzopCodec.java [139:150]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  public CompressionInputStream createInputStream(final InputStream in) throws IOException {
    final Decompressor decompressor = CodecPool.getDecompressor(this);
    // maintain backwards compatibility re: returning the decompressor to the CodecPool
    InputStream inputStream = new FilterInputStream(in) {
      @Override
      public void close() throws IOException {
        CodecPool.returnDecompressor(decompressor);
        super.close();
      }
    };
    return createInputStream(inputStream, decompressor);
  }