org.glassfish.jersey.core/jersey-server/2.30.1 : org/glassfish/jersey/server/ChunkedOutput.class

ChunkedOutput
https://projects.eclipse.org/projects/ee4j.jersey/jersey-server: Jersey core server implementation (Eclipse Foundation)
Petr Bouda
Pavel Bucek (Oracle Corporation)
Michal Gajdos
Petr Janouch
Libor Kramolis
Adam Lindenthal
Jakub Podlesak (Oracle Corporation)
Marek Potociar
Stepan Vavra
Roman Grigoriadi (Oracle Corporation)
Lukas Jungmann (Oracle Corporation)
Dmitry Kornilov (Oracle Corporation)
Tomas Kraus (Oracle Corporation)
Tomas Langer (Oracle Corporation)
Maxim Nesen (Oracle Corporation)
Santiago Pericas-Geertsen (Oracle Corporation)
Jan Supol (Oracle Corporation)
public class org.glassfish.jersey.server.ChunkedOutput<T> extends javax.ws.rs.core.GenericType<T> implements java.io.Closeable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.glassfish.jersey.server.ChunkedOutput
  super_class: javax.ws.rs.core.GenericType
{
  private static final byte[] ZERO_LENGTH_DELIMITER;
    descriptor: [B
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.util.concurrent.BlockingDeque<T> queue;
    descriptor: Ljava/util/concurrent/BlockingDeque;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/BlockingDeque<TT;>;

  private final byte[] chunkDelimiter;
    descriptor: [B
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicBoolean resumed;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private boolean flushing;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private volatile boolean closed;
    descriptor: Z
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile org.glassfish.jersey.server.AsyncContext asyncContext;
    descriptor: Lorg/glassfish/jersey/server/AsyncContext;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile org.glassfish.jersey.process.internal.RequestScope requestScope;
    descriptor: Lorg/glassfish/jersey/process/internal/RequestScope;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile org.glassfish.jersey.process.internal.RequestContext requestScopeContext;
    descriptor: Lorg/glassfish/jersey/process/internal/RequestContext;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile org.glassfish.jersey.server.ContainerRequest requestContext;
    descriptor: Lorg/glassfish/jersey/server/ContainerRequest;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile org.glassfish.jersey.server.ContainerResponse responseContext;
    descriptor: Lorg/glassfish/jersey/server/ContainerResponse;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile javax.ws.rs.container.ConnectionCallback connectionCallback;
    descriptor: Ljavax/ws/rs/container/ConnectionCallback;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 51
            iconst_0
            newarray 8
            putstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  protected void <init>();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
         0: .line 73
            aload 0 /* this */
            invokespecial javax.ws.rs.core.GenericType.<init>:()V
         1: .line 53
            aload 0 /* this */
            new java.util.concurrent.LinkedBlockingDeque
            dup
            invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
            putfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
         2: .line 55
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 57
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.flushing:Z
         4: .line 59
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         5: .line 74
            aload 0 /* this */
            getstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         6: .line 75
            return
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;

  public void <init>(java.lang.reflect.Type);
    descriptor: (Ljava/lang/reflect/Type;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // java.lang.reflect.Type chunkType
         0: .line 83
            aload 0 /* this */
            aload 1 /* chunkType */
            invokespecial javax.ws.rs.core.GenericType.<init>:(Ljava/lang/reflect/Type;)V
         1: .line 53
            aload 0 /* this */
            new java.util.concurrent.LinkedBlockingDeque
            dup
            invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
            putfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
         2: .line 55
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 57
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.flushing:Z
         4: .line 59
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         5: .line 84
            aload 0 /* this */
            getstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         6: .line 85
            return
        end local 1 // java.lang.reflect.Type chunkType
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0    7     1  chunkType  Ljava/lang/reflect/Type;
    MethodParameters:
           Name  Flags
      chunkType  final

  protected void <init>(byte[]);
    descriptor: ([B)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // byte[] chunkDelimiter
         0: .line 93
            aload 0 /* this */
            invokespecial javax.ws.rs.core.GenericType.<init>:()V
         1: .line 53
            aload 0 /* this */
            new java.util.concurrent.LinkedBlockingDeque
            dup
            invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
            putfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
         2: .line 55
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 57
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.flushing:Z
         4: .line 59
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         5: .line 94
            aload 1 /* chunkDelimiter */
            arraylength
            ifle 9
         6: .line 95
            aload 0 /* this */
            aload 1 /* chunkDelimiter */
            arraylength
            newarray 8
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         7: .line 96
            aload 1 /* chunkDelimiter */
            iconst_0
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
            iconst_0
            aload 1 /* chunkDelimiter */
            arraylength
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
         8: .line 97
            goto 10
         9: .line 98
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput byte[]
      StackMap stack:
            aload 0 /* this */
            getstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
        10: .line 100
      StackMap locals:
      StackMap stack:
            return
        end local 1 // byte[] chunkDelimiter
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   11     0            this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0   11     1  chunkDelimiter  [B
    MethodParameters:
                Name  Flags
      chunkDelimiter  final

  protected void <init>(byte[], javax.inject.Provider<org.glassfish.jersey.server.AsyncContext>);
    descriptor: ([BLjavax/inject/Provider;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // byte[] chunkDelimiter
        start local 2 // javax.inject.Provider asyncContextProvider
         0: .line 108
            aload 0 /* this */
            invokespecial javax.ws.rs.core.GenericType.<init>:()V
         1: .line 53
            aload 0 /* this */
            new java.util.concurrent.LinkedBlockingDeque
            dup
            invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
            putfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
         2: .line 55
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 57
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.flushing:Z
         4: .line 59
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         5: .line 109
            aload 1 /* chunkDelimiter */
            arraylength
            ifle 9
         6: .line 110
            aload 0 /* this */
            aload 1 /* chunkDelimiter */
            arraylength
            newarray 8
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         7: .line 111
            aload 1 /* chunkDelimiter */
            iconst_0
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
            iconst_0
            aload 1 /* chunkDelimiter */
            arraylength
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
         8: .line 112
            goto 10
         9: .line 113
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput byte[] javax.inject.Provider
      StackMap stack:
            aload 0 /* this */
            getstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
        10: .line 116
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* asyncContextProvider */
            ifnonnull 11
            aconst_null
            goto 12
      StackMap locals:
      StackMap stack: org.glassfish.jersey.server.ChunkedOutput
        11: aload 2 /* asyncContextProvider */
            invokeinterface javax.inject.Provider.get:()Ljava/lang/Object;
            checkcast org.glassfish.jersey.server.AsyncContext
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput byte[] javax.inject.Provider
      StackMap stack: org.glassfish.jersey.server.ChunkedOutput org.glassfish.jersey.server.AsyncContext
        12: putfield org.glassfish.jersey.server.ChunkedOutput.asyncContext:Lorg/glassfish/jersey/server/AsyncContext;
        13: .line 117
            return
        end local 2 // javax.inject.Provider asyncContextProvider
        end local 1 // byte[] chunkDelimiter
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0   14     0                  this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0   14     1        chunkDelimiter  [B
            0   14     2  asyncContextProvider  Ljavax/inject/Provider<Lorg/glassfish/jersey/server/AsyncContext;>;
    Signature: ([BLjavax/inject/Provider<Lorg/glassfish/jersey/server/AsyncContext;>;)V
    MethodParameters:
                      Name  Flags
      chunkDelimiter        final
      asyncContextProvider  

  public void <init>(java.lang.reflect.Type, byte[]);
    descriptor: (Ljava/lang/reflect/Type;[B)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // java.lang.reflect.Type chunkType
        start local 2 // byte[] chunkDelimiter
         0: .line 127
            aload 0 /* this */
            aload 1 /* chunkType */
            invokespecial javax.ws.rs.core.GenericType.<init>:(Ljava/lang/reflect/Type;)V
         1: .line 53
            aload 0 /* this */
            new java.util.concurrent.LinkedBlockingDeque
            dup
            invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
            putfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
         2: .line 55
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 57
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.flushing:Z
         4: .line 59
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         5: .line 128
            aload 2 /* chunkDelimiter */
            arraylength
            ifle 9
         6: .line 129
            aload 0 /* this */
            aload 2 /* chunkDelimiter */
            arraylength
            newarray 8
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         7: .line 130
            aload 2 /* chunkDelimiter */
            iconst_0
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
            iconst_0
            aload 2 /* chunkDelimiter */
            arraylength
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
         8: .line 131
            goto 10
         9: .line 132
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.reflect.Type byte[]
      StackMap stack:
            aload 0 /* this */
            getstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
        10: .line 134
      StackMap locals:
      StackMap stack:
            return
        end local 2 // byte[] chunkDelimiter
        end local 1 // java.lang.reflect.Type chunkType
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   11     0            this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0   11     1       chunkType  Ljava/lang/reflect/Type;
            0   11     2  chunkDelimiter  [B
    MethodParameters:
                Name  Flags
      chunkType       final
      chunkDelimiter  final

  protected void <init>(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // java.lang.String chunkDelimiter
         0: .line 142
            aload 0 /* this */
            invokespecial javax.ws.rs.core.GenericType.<init>:()V
         1: .line 53
            aload 0 /* this */
            new java.util.concurrent.LinkedBlockingDeque
            dup
            invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
            putfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
         2: .line 55
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 57
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.flushing:Z
         4: .line 59
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         5: .line 143
            aload 1 /* chunkDelimiter */
            invokevirtual java.lang.String.isEmpty:()Z
            ifeq 8
         6: .line 144
            aload 0 /* this */
            getstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         7: .line 145
            goto 9
         8: .line 146
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.String
      StackMap stack:
            aload 0 /* this */
            aload 1 /* chunkDelimiter */
            invokevirtual java.lang.String.getBytes:()[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         9: .line 148
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.String chunkDelimiter
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   10     0            this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0   10     1  chunkDelimiter  Ljava/lang/String;
    MethodParameters:
                Name  Flags
      chunkDelimiter  final

  public void <init>(java.lang.reflect.Type, java.lang.String);
    descriptor: (Ljava/lang/reflect/Type;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // java.lang.reflect.Type chunkType
        start local 2 // java.lang.String chunkDelimiter
         0: .line 158
            aload 0 /* this */
            aload 1 /* chunkType */
            invokespecial javax.ws.rs.core.GenericType.<init>:(Ljava/lang/reflect/Type;)V
         1: .line 53
            aload 0 /* this */
            new java.util.concurrent.LinkedBlockingDeque
            dup
            invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
            putfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
         2: .line 55
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 57
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.flushing:Z
         4: .line 59
            aload 0 /* this */
            iconst_0
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         5: .line 159
            aload 2 /* chunkDelimiter */
            invokevirtual java.lang.String.isEmpty:()Z
            ifeq 8
         6: .line 160
            aload 0 /* this */
            getstatic org.glassfish.jersey.server.ChunkedOutput.ZERO_LENGTH_DELIMITER:[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         7: .line 161
            goto 9
         8: .line 162
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.reflect.Type java.lang.String
      StackMap stack:
            aload 0 /* this */
            aload 2 /* chunkDelimiter */
            invokevirtual java.lang.String.getBytes:()[B
            putfield org.glassfish.jersey.server.ChunkedOutput.chunkDelimiter:[B
         9: .line 164
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.String chunkDelimiter
        end local 1 // java.lang.reflect.Type chunkType
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   10     0            this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0   10     1       chunkType  Ljava/lang/reflect/Type;
            0   10     2  chunkDelimiter  Ljava/lang/String;
    MethodParameters:
                Name  Flags
      chunkType       final
      chunkDelimiter  final

  public void write();
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // java.lang.Object chunk
         0: .line 173
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
            ifeq 2
         1: .line 174
            new java.io.IOException
            dup
            invokestatic org.glassfish.jersey.server.internal.LocalizationMessages.CHUNKED_OUTPUT_CLOSED:()Ljava/lang/String;
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 177
      StackMap locals:
      StackMap stack:
            aload 1 /* chunk */
            ifnull 4
         3: .line 178
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
            aload 1 /* chunk */
            invokeinterface java.util.concurrent.BlockingDeque.add:(Ljava/lang/Object;)Z
            pop
         4: .line 181
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.glassfish.jersey.server.ChunkedOutput.flushQueue:()V
         5: .line 182
            return
        end local 1 // java.lang.Object chunk
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    6     0   this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0    6     1  chunk  TT;
    Exceptions:
      throws java.io.IOException
    Signature: (TT;)V
    MethodParameters:
       Name  Flags
      chunk  final

  protected void flushQueue();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=5, args_size=1
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
         0: .line 185
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.resumed:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 2
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.asyncContext:Lorg/glassfish/jersey/server/AsyncContext;
            ifnull 2
         1: .line 186
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.asyncContext:Lorg/glassfish/jersey/server/AsyncContext;
            aload 0 /* this */
            invokeinterface org.glassfish.jersey.server.AsyncContext.resume:(Ljava/lang/Object;)Z
            pop
         2: .line 189
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.requestScopeContext:Lorg/glassfish/jersey/process/internal/RequestContext;
            ifnull 3
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.requestContext:Lorg/glassfish/jersey/server/ContainerRequest;
            ifnull 3
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.responseContext:Lorg/glassfish/jersey/server/ContainerResponse;
            ifnonnull 4
         3: .line 190
      StackMap locals:
      StackMap stack:
            return
         4: .line 193
      StackMap locals:
      StackMap stack:
            aconst_null
            astore 1 /* ex */
        start local 1 // java.lang.Exception ex
         5: .line 195
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.requestScope:Lorg/glassfish/jersey/process/internal/RequestScope;
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.requestScopeContext:Lorg/glassfish/jersey/process/internal/RequestContext;
            new org.glassfish.jersey.server.ChunkedOutput$1
            dup
            aload 0 /* this */
            invokespecial org.glassfish.jersey.server.ChunkedOutput$1.<init>:(Lorg/glassfish/jersey/server/ChunkedOutput;)V
            invokevirtual org.glassfish.jersey.process.internal.RequestScope.runInScope:(Lorg/glassfish/jersey/process/internal/RequestContext;Ljava/util/concurrent/Callable;)Ljava/lang/Object;
            pop
         6: .line 286
            goto 36
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.Exception
      StackMap stack: java.lang.Exception
         7: astore 2 /* e */
        start local 2 // java.lang.Exception e
         8: .line 287
            aload 0 /* this */
            iconst_1
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         9: .line 289
            aload 2 /* e */
            astore 1 /* ex */
        end local 2 // java.lang.Exception e
        10: .line 291
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
            ifeq 48
        11: .line 293
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.responseContext:Lorg/glassfish/jersey/server/ContainerResponse;
            invokevirtual org.glassfish.jersey.server.ContainerResponse.close:()V
        12: .line 294
            goto 17
      StackMap locals:
      StackMap stack: java.lang.Exception
        13: astore 4 /* e */
        start local 4 // java.lang.Exception e
        14: .line 297
            aload 1 /* ex */
            ifnonnull 15
            aload 4 /* e */
            goto 16
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.Exception top top java.lang.Exception
      StackMap stack:
        15: aload 1 /* ex */
      StackMap locals:
      StackMap stack: java.lang.Exception
        16: astore 1 /* ex */
        end local 4 // java.lang.Exception e
        17: .line 300
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.Exception
      StackMap stack:
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.requestScopeContext:Lorg/glassfish/jersey/process/internal/RequestContext;
            invokeinterface org.glassfish.jersey.process.internal.RequestContext.release:()V
        18: .line 303
            aload 1 /* ex */
            instanceof java.io.IOException
            ifeq 20
        19: .line 305
            aload 1 /* ex */
            checkcast java.io.IOException
            athrow
        20: .line 306
      StackMap locals:
      StackMap stack:
            aload 1 /* ex */
            instanceof java.lang.RuntimeException
            ifeq 48
        21: .line 308
            aload 1 /* ex */
            checkcast java.lang.RuntimeException
            athrow
        22: .line 290
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 3
        23: .line 291
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
            ifeq 35
        24: .line 293
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.responseContext:Lorg/glassfish/jersey/server/ContainerResponse;
            invokevirtual org.glassfish.jersey.server.ContainerResponse.close:()V
        25: .line 294
            goto 30
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.Exception top java.lang.Throwable
      StackMap stack: java.lang.Exception
        26: astore 4 /* e */
        start local 4 // java.lang.Exception e
        27: .line 297
            aload 1 /* ex */
            ifnonnull 28
            aload 4 /* e */
            goto 29
      StackMap locals: java.lang.Exception
      StackMap stack:
        28: aload 1 /* ex */
      StackMap locals:
      StackMap stack: java.lang.Exception
        29: astore 1 /* ex */
        end local 4 // java.lang.Exception e
        30: .line 300
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.requestScopeContext:Lorg/glassfish/jersey/process/internal/RequestContext;
            invokeinterface org.glassfish.jersey.process.internal.RequestContext.release:()V
        31: .line 303
            aload 1 /* ex */
            instanceof java.io.IOException
            ifeq 33
        32: .line 305
            aload 1 /* ex */
            checkcast java.io.IOException
            athrow
        33: .line 306
      StackMap locals:
      StackMap stack:
            aload 1 /* ex */
            instanceof java.lang.RuntimeException
            ifeq 35
        34: .line 308
            aload 1 /* ex */
            checkcast java.lang.RuntimeException
            athrow
        35: .line 311
      StackMap locals:
      StackMap stack:
            aload 3
            athrow
        36: .line 291
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.Exception
      StackMap stack:
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
            ifeq 48
        37: .line 293
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.responseContext:Lorg/glassfish/jersey/server/ContainerResponse;
            invokevirtual org.glassfish.jersey.server.ContainerResponse.close:()V
        38: .line 294
            goto 43
      StackMap locals:
      StackMap stack: java.lang.Exception
        39: astore 4 /* e */
        start local 4 // java.lang.Exception e
        40: .line 297
            aload 1 /* ex */
            ifnonnull 41
            aload 4 /* e */
            goto 42
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.Exception top top java.lang.Exception
      StackMap stack:
        41: aload 1 /* ex */
      StackMap locals:
      StackMap stack: java.lang.Exception
        42: astore 1 /* ex */
        end local 4 // java.lang.Exception e
        43: .line 300
      StackMap locals: org.glassfish.jersey.server.ChunkedOutput java.lang.Exception
      StackMap stack:
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.requestScopeContext:Lorg/glassfish/jersey/process/internal/RequestContext;
            invokeinterface org.glassfish.jersey.process.internal.RequestContext.release:()V
        44: .line 303
            aload 1 /* ex */
            instanceof java.io.IOException
            ifeq 46
        45: .line 305
            aload 1 /* ex */
            checkcast java.io.IOException
            athrow
        46: .line 306
      StackMap locals:
      StackMap stack:
            aload 1 /* ex */
            instanceof java.lang.RuntimeException
            ifeq 48
        47: .line 308
            aload 1 /* ex */
            checkcast java.lang.RuntimeException
            athrow
        48: .line 312
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Exception ex
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   49     0  this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            5   49     1    ex  Ljava/lang/Exception;
            8   10     2     e  Ljava/lang/Exception;
           14   17     4     e  Ljava/lang/Exception;
           27   30     4     e  Ljava/lang/Exception;
           40   43     4     e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           5     6       7  Class java.lang.Exception
          11    12      13  Class java.lang.Exception
           5    10      22  any
          24    25      26  Class java.lang.Exception
          37    38      39  Class java.lang.Exception
    Exceptions:
      throws java.io.IOException

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
         0: .line 320
            aload 0 /* this */
            iconst_1
            putfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
         1: .line 321
            aload 0 /* this */
            invokevirtual org.glassfish.jersey.server.ChunkedOutput.flushQueue:()V
         2: .line 322
            return
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
    Exceptions:
      throws java.io.IOException

  public boolean isClosed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
         0: .line 333
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.closed:Z
            ireturn
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;

  public boolean equals(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // java.lang.Object obj
         0: .line 339
            aload 0 /* this */
            aload 1 /* obj */
            if_acmpne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 1 // java.lang.Object obj
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0    2     1   obj  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      obj   final

  public int hashCode();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
         0: .line 344
            aload 0 /* this */
            invokespecial javax.ws.rs.core.GenericType.hashCode:()I
            istore 1 /* result */
        start local 1 // int result
         1: .line 345
            bipush 31
            iload 1 /* result */
            imul
            aload 0 /* this */
            getfield org.glassfish.jersey.server.ChunkedOutput.queue:Ljava/util/concurrent/BlockingDeque;
            invokeinterface java.util.concurrent.BlockingDeque.hashCode:()I
            iadd
            istore 1 /* result */
         2: .line 346
            iload 1 /* result */
            ireturn
        end local 1 // int result
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            1    3     1  result  I

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
         0: .line 351
            new java.lang.StringBuilder
            dup
            ldc "ChunkedOutput<"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            invokevirtual org.glassfish.jersey.server.ChunkedOutput.getType:()Ljava/lang/reflect/Type;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc ">"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;

  void setContext(org.glassfish.jersey.process.internal.RequestScope, org.glassfish.jersey.process.internal.RequestContext, org.glassfish.jersey.server.ContainerRequest, org.glassfish.jersey.server.ContainerResponse, javax.ws.rs.container.ConnectionCallback);
    descriptor: (Lorg/glassfish/jersey/process/internal/RequestScope;Lorg/glassfish/jersey/process/internal/RequestContext;Lorg/glassfish/jersey/server/ContainerRequest;Lorg/glassfish/jersey/server/ContainerResponse;Ljavax/ws/rs/container/ConnectionCallback;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=6, args_size=6
        start local 0 // org.glassfish.jersey.server.ChunkedOutput this
        start local 1 // org.glassfish.jersey.process.internal.RequestScope requestScope
        start local 2 // org.glassfish.jersey.process.internal.RequestContext requestScopeContext
        start local 3 // org.glassfish.jersey.server.ContainerRequest requestContext
        start local 4 // org.glassfish.jersey.server.ContainerResponse responseContext
        start local 5 // javax.ws.rs.container.ConnectionCallback connectionCallbackRunner
         0: .line 369
            aload 0 /* this */
            aload 1 /* requestScope */
            putfield org.glassfish.jersey.server.ChunkedOutput.requestScope:Lorg/glassfish/jersey/process/internal/RequestScope;
         1: .line 370
            aload 0 /* this */
            aload 2 /* requestScopeContext */
            putfield org.glassfish.jersey.server.ChunkedOutput.requestScopeContext:Lorg/glassfish/jersey/process/internal/RequestContext;
         2: .line 371
            aload 0 /* this */
            aload 3 /* requestContext */
            putfield org.glassfish.jersey.server.ChunkedOutput.requestContext:Lorg/glassfish/jersey/server/ContainerRequest;
         3: .line 372
            aload 0 /* this */
            aload 4 /* responseContext */
            putfield org.glassfish.jersey.server.ChunkedOutput.responseContext:Lorg/glassfish/jersey/server/ContainerResponse;
         4: .line 373
            aload 0 /* this */
            aload 5 /* connectionCallbackRunner */
            putfield org.glassfish.jersey.server.ChunkedOutput.connectionCallback:Ljavax/ws/rs/container/ConnectionCallback;
         5: .line 374
            aload 0 /* this */
            invokevirtual org.glassfish.jersey.server.ChunkedOutput.flushQueue:()V
         6: .line 375
            return
        end local 5 // javax.ws.rs.container.ConnectionCallback connectionCallbackRunner
        end local 4 // org.glassfish.jersey.server.ContainerResponse responseContext
        end local 3 // org.glassfish.jersey.server.ContainerRequest requestContext
        end local 2 // org.glassfish.jersey.process.internal.RequestContext requestScopeContext
        end local 1 // org.glassfish.jersey.process.internal.RequestScope requestScope
        end local 0 // org.glassfish.jersey.server.ChunkedOutput this
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0    7     0                      this  Lorg/glassfish/jersey/server/ChunkedOutput<TT;>;
            0    7     1              requestScope  Lorg/glassfish/jersey/process/internal/RequestScope;
            0    7     2       requestScopeContext  Lorg/glassfish/jersey/process/internal/RequestContext;
            0    7     3            requestContext  Lorg/glassfish/jersey/server/ContainerRequest;
            0    7     4           responseContext  Lorg/glassfish/jersey/server/ContainerResponse;
            0    7     5  connectionCallbackRunner  Ljavax/ws/rs/container/ConnectionCallback;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
                          Name  Flags
      requestScope              final
      requestScopeContext       final
      requestContext            final
      responseContext           final
      connectionCallbackRunner  final
}
Signature: <T:Ljava/lang/Object;>Ljavax/ws/rs/core/GenericType<TT;>;Ljava/io/Closeable;
SourceFile: "ChunkedOutput.java"
NestMembers:
  org.glassfish.jersey.server.ChunkedOutput$1
InnerClasses:
  org.glassfish.jersey.server.ChunkedOutput$1
/

org.glassfish.jersey.core/ jersey-server/ 2.30.1/ org/glassfish/jersey/server/ChunkedOutput.class
