https://commons.apache.org/proper/commons-compress/: Apache Commons Compress software defines an API for working with compression and archive formats. These include: bzip2, gzip, pack200, lzma, xz, Snappy, traditional Unix Compress, DEFLATE, DEFLATE64, LZ4, Brotli, Zstandard and ar, cpio, jar, tar, zip, dump, 7z, arj. (The Apache Software Foundation)
  • Wolfgang Glas
  • Christian Kohlschütte
  • Bear Giles
  • Michael Kuss
  • Lasse Collin
  • John Kodis
  • BELUGA BEHR
  • Simon Spero
  • Michael Hausegger
  • Torsten Curdt
  • Stefan Bodewig
  • Sebastian Bazley
  • Christian Grobmeier
  • Julius Davies
  • Damjan Jovanovic
  • Emmanuel Bourg
  • Gary Gregory
  • Rob Tompkins 
public class org.apache.commons.compress.archivers.zip.ScatterZipOutputStream implements java.io.Closeable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.commons.compress.archivers.zip.ScatterZipOutputStream
  super_class: java.lang.Object
{
  private final java.util.Queue<org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry> items;
    descriptor: Ljava/util/Queue;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Queue<Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream$CompressedEntry;>;

  private final org.apache.commons.compress.parallel.ScatterGatherBackingStore backingStore;
    descriptor: Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.commons.compress.archivers.zip.StreamCompressor streamCompressor;
    descriptor: Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>(org.apache.commons.compress.parallel.ScatterGatherBackingStore, org.apache.commons.compress.archivers.zip.StreamCompressor);
    descriptor: (Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;Lorg/apache/commons/compress/archivers/zip/StreamCompressor;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
        start local 1 // org.apache.commons.compress.parallel.ScatterGatherBackingStore backingStore
        start local 2 // org.apache.commons.compress.archivers.zip.StreamCompressor streamCompressor
         0: .line 82
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 49
            aload 0 /* this */
            new java.util.concurrent.ConcurrentLinkedQueue
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
            putfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.items:Ljava/util/Queue;
         2: .line 84
            aload 0 /* this */
            aload 1 /* backingStore */
            putfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.backingStore:Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;
         3: .line 85
            aload 0 /* this */
            aload 2 /* streamCompressor */
            putfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.streamCompressor:Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
         4: .line 86
            return
        end local 2 // org.apache.commons.compress.archivers.zip.StreamCompressor streamCompressor
        end local 1 // org.apache.commons.compress.parallel.ScatterGatherBackingStore backingStore
        end local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    5     0              this  Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream;
            0    5     1      backingStore  Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;
            0    5     2  streamCompressor  Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
    MethodParameters:
                  Name  Flags
      backingStore      final
      streamCompressor  final

  public void addArchiveEntry(org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest);
    descriptor: (Lorg/apache/commons/compress/archivers/zip/ZipArchiveEntryRequest;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=10, locals=5, args_size=2
        start local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
        start local 1 // org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest zipArchiveEntryRequest
         0: .line 95
            aconst_null
            astore 2
            aconst_null
            astore 3
         1: aload 1 /* zipArchiveEntryRequest */
            invokevirtual org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest.getPayloadStream:()Ljava/io/InputStream;
            astore 4 /* payloadStream */
        start local 4 // java.io.InputStream payloadStream
         2: .line 96
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.streamCompressor:Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
            aload 4 /* payloadStream */
            aload 1 /* zipArchiveEntryRequest */
            invokevirtual org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest.getMethod:()I
            invokevirtual org.apache.commons.compress.archivers.zip.StreamCompressor.deflate:(Ljava/io/InputStream;I)V
         3: .line 97
            aload 4 /* payloadStream */
            ifnull 9
            aload 4 /* payloadStream */
            invokevirtual java.io.InputStream.close:()V
            goto 9
      StackMap locals: org.apache.commons.compress.archivers.zip.ScatterZipOutputStream org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest java.lang.Throwable java.lang.Throwable java.io.InputStream
      StackMap stack: java.lang.Throwable
         4: astore 2
            aload 4 /* payloadStream */
            ifnull 5
            aload 4 /* payloadStream */
            invokevirtual java.io.InputStream.close:()V
        end local 4 // java.io.InputStream payloadStream
      StackMap locals:
      StackMap stack:
         5: aload 2
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
         6: astore 3
            aload 2
            ifnonnull 7
            aload 3
            astore 2
            goto 8
      StackMap locals:
      StackMap stack:
         7: aload 2
            aload 3
            if_acmpeq 8
            aload 2
            aload 3
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
         8: aload 2
            athrow
         9: .line 98
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.items:Ljava/util/Queue;
            new org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry
            dup
            aload 1 /* zipArchiveEntryRequest */
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.streamCompressor:Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
            invokevirtual org.apache.commons.compress.archivers.zip.StreamCompressor.getCrc32:()J
        10: .line 99
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.streamCompressor:Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
            invokevirtual org.apache.commons.compress.archivers.zip.StreamCompressor.getBytesWrittenForLastEntry:()J
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.streamCompressor:Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
            invokevirtual org.apache.commons.compress.archivers.zip.StreamCompressor.getBytesRead:()J
            invokespecial org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry.<init>:(Lorg/apache/commons/compress/archivers/zip/ZipArchiveEntryRequest;JJJ)V
        11: .line 98
            invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
            pop
        12: .line 100
            return
        end local 1 // org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest zipArchiveEntryRequest
        end local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0   13     0                    this  Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream;
            0   13     1  zipArchiveEntryRequest  Lorg/apache/commons/compress/archivers/zip/ZipArchiveEntryRequest;
            2    5     4           payloadStream  Ljava/io/InputStream;
      Exception table:
        from    to  target  type
           2     3       4  any
           1     6       6  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
                        Name  Flags
      zipArchiveEntryRequest  final

  public void writeTo(org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream);
    descriptor: (Lorg/apache/commons/compress/archivers/zip/ZipArchiveOutputStream;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=10, args_size=2
        start local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
        start local 1 // org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream target
         0: .line 109
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.backingStore:Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;
            invokeinterface org.apache.commons.compress.parallel.ScatterGatherBackingStore.closeForWriting:()V
         1: .line 110
            aconst_null
            astore 2
            aconst_null
            astore 3
         2: aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.backingStore:Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;
            invokeinterface org.apache.commons.compress.parallel.ScatterGatherBackingStore.getInputStream:()Ljava/io/InputStream;
            astore 4 /* data */
        start local 4 // java.io.InputStream data
         3: .line 111
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.items:Ljava/util/Queue;
            invokeinterface java.util.Queue.iterator:()Ljava/util/Iterator;
            astore 6
            goto 16
      StackMap locals: org.apache.commons.compress.archivers.zip.ScatterZipOutputStream org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream java.lang.Throwable java.lang.Throwable java.io.InputStream top java.util.Iterator
      StackMap stack:
         4: aload 6
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry
            astore 5 /* compressedEntry */
        start local 5 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry compressedEntry
         5: .line 112
            aconst_null
            astore 7
            aconst_null
            astore 8
         6: new org.apache.commons.compress.utils.BoundedInputStream
            dup
            aload 4 /* data */
         7: .line 113
            aload 5 /* compressedEntry */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry.compressedSize:J
         8: .line 112
            invokespecial org.apache.commons.compress.utils.BoundedInputStream.<init>:(Ljava/io/InputStream;J)V
            astore 9 /* rawStream */
        start local 9 // org.apache.commons.compress.utils.BoundedInputStream rawStream
         9: .line 114
            aload 1 /* target */
            aload 5 /* compressedEntry */
            invokevirtual org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry.transferToArchiveEntry:()Lorg/apache/commons/compress/archivers/zip/ZipArchiveEntry;
            aload 9 /* rawStream */
            invokevirtual org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream.addRawArchiveEntry:(Lorg/apache/commons/compress/archivers/zip/ZipArchiveEntry;Ljava/io/InputStream;)V
        10: .line 115
            aload 9 /* rawStream */
            ifnull 16
            aload 9 /* rawStream */
            invokevirtual org.apache.commons.compress.utils.BoundedInputStream.close:()V
            goto 16
      StackMap locals: org.apache.commons.compress.archivers.zip.ScatterZipOutputStream org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream java.lang.Throwable java.lang.Throwable java.io.InputStream org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry java.util.Iterator java.lang.Throwable java.lang.Throwable org.apache.commons.compress.utils.BoundedInputStream
      StackMap stack: java.lang.Throwable
        11: astore 7
            aload 9 /* rawStream */
            ifnull 12
            aload 9 /* rawStream */
            invokevirtual org.apache.commons.compress.utils.BoundedInputStream.close:()V
        end local 9 // org.apache.commons.compress.utils.BoundedInputStream rawStream
      StackMap locals:
      StackMap stack:
        12: aload 7
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        13: astore 8
            aload 7
            ifnonnull 14
            aload 8
            astore 7
            goto 15
      StackMap locals:
      StackMap stack:
        14: aload 7
            aload 8
            if_acmpeq 15
            aload 7
            aload 8
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        15: aload 7
            athrow
        end local 5 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry compressedEntry
        16: .line 111
      StackMap locals: org.apache.commons.compress.archivers.zip.ScatterZipOutputStream org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream java.lang.Throwable java.lang.Throwable java.io.InputStream top java.util.Iterator
      StackMap stack:
            aload 6
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
        17: .line 117
            aload 4 /* data */
            ifnull 23
            aload 4 /* data */
            invokevirtual java.io.InputStream.close:()V
            goto 23
      StackMap locals: org.apache.commons.compress.archivers.zip.ScatterZipOutputStream org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream java.lang.Throwable java.lang.Throwable java.io.InputStream
      StackMap stack: java.lang.Throwable
        18: astore 2
            aload 4 /* data */
            ifnull 19
            aload 4 /* data */
            invokevirtual java.io.InputStream.close:()V
        end local 4 // java.io.InputStream data
      StackMap locals:
      StackMap stack:
        19: aload 2
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        20: astore 3
            aload 2
            ifnonnull 21
            aload 3
            astore 2
            goto 22
      StackMap locals:
      StackMap stack:
        21: aload 2
            aload 3
            if_acmpeq 22
            aload 2
            aload 3
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        22: aload 2
            athrow
        23: .line 118
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream target
        end local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   24     0             this  Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream;
            0   24     1           target  Lorg/apache/commons/compress/archivers/zip/ZipArchiveOutputStream;
            3   19     4             data  Ljava/io/InputStream;
            5   16     5  compressedEntry  Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream$CompressedEntry;
            9   12     9        rawStream  Lorg/apache/commons/compress/utils/BoundedInputStream;
      Exception table:
        from    to  target  type
           9    10      11  any
           6    13      13  any
           3    17      18  any
           2    20      20  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      target  final

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
         0: .line 128
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.backingStore:Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;
            invokeinterface org.apache.commons.compress.parallel.ScatterGatherBackingStore.close:()V
         1: .line 129
            goto 5
      StackMap locals:
      StackMap stack: java.lang.Throwable
         2: astore 1
         3: .line 130
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.streamCompressor:Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
            invokevirtual org.apache.commons.compress.archivers.zip.StreamCompressor.close:()V
         4: .line 131
            aload 1
            athrow
         5: .line 130
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.streamCompressor:Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
            invokevirtual org.apache.commons.compress.archivers.zip.StreamCompressor.close:()V
         6: .line 132
            return
        end local 0 // org.apache.commons.compress.archivers.zip.ScatterZipOutputStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream;
      Exception table:
        from    to  target  type
           0     2       2  any
    Exceptions:
      throws java.io.IOException

  public static org.apache.commons.compress.archivers.zip.ScatterZipOutputStream fileBased(java.io.File);
    descriptor: (Ljava/io/File;)Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.io.File file
         0: .line 142
            aload 0 /* file */
            iconst_m1
            invokestatic org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.fileBased:(Ljava/io/File;I)Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream;
            areturn
        end local 0 // java.io.File file
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  file  Ljava/io/File;
    Exceptions:
      throws java.io.FileNotFoundException
    MethodParameters:
      Name  Flags
      file  final

  public static org.apache.commons.compress.archivers.zip.ScatterZipOutputStream fileBased(java.io.File, int);
    descriptor: (Ljava/io/File;I)Lorg/apache/commons/compress/archivers/zip/ScatterZipOutputStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // java.io.File file
        start local 1 // int compressionLevel
         0: .line 154
            new org.apache.commons.compress.parallel.FileBasedScatterGatherBackingStore
            dup
            aload 0 /* file */
            invokespecial org.apache.commons.compress.parallel.FileBasedScatterGatherBackingStore.<init>:(Ljava/io/File;)V
            astore 2 /* bs */
        start local 2 // org.apache.commons.compress.parallel.ScatterGatherBackingStore bs
         1: .line 156
            iload 1 /* compressionLevel */
            aload 2 /* bs */
            invokestatic org.apache.commons.compress.archivers.zip.StreamCompressor.create:(ILorg/apache/commons/compress/parallel/ScatterGatherBackingStore;)Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
            astore 3 /* sc */
        start local 3 // org.apache.commons.compress.archivers.zip.StreamCompressor sc
         2: .line 157
            new org.apache.commons.compress.archivers.zip.ScatterZipOutputStream
            dup
            aload 2 /* bs */
            aload 3 /* sc */
            invokespecial org.apache.commons.compress.archivers.zip.ScatterZipOutputStream.<init>:(Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;Lorg/apache/commons/compress/archivers/zip/StreamCompressor;)V
            areturn
        end local 3 // org.apache.commons.compress.archivers.zip.StreamCompressor sc
        end local 2 // org.apache.commons.compress.parallel.ScatterGatherBackingStore bs
        end local 1 // int compressionLevel
        end local 0 // java.io.File file
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    3     0              file  Ljava/io/File;
            0    3     1  compressionLevel  I
            1    3     2                bs  Lorg/apache/commons/compress/parallel/ScatterGatherBackingStore;
            2    3     3                sc  Lorg/apache/commons/compress/archivers/zip/StreamCompressor;
    Exceptions:
      throws java.io.FileNotFoundException
    MethodParameters:
                  Name  Flags
      file              final
      compressionLevel  final
}
SourceFile: "ScatterZipOutputStream.java"
NestMembers:
  org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry
InnerClasses:
  private CompressedEntry = org.apache.commons.compress.archivers.zip.ScatterZipOutputStream$CompressedEntry of org.apache.commons.compress.archivers.zip.ScatterZipOutputStream