public class org.glassfish.jersey.client.ChunkedInput<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.client.ChunkedInput
super_class: javax.ws.rs.core.GenericType
{
private static final java.util.logging.Logger LOGGER;
descriptor: Ljava/util/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.util.concurrent.atomic.AtomicBoolean closed;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private org.glassfish.jersey.client.ChunkParser parser;
descriptor: Lorg/glassfish/jersey/client/ChunkParser;
flags: (0x0002) ACC_PRIVATE
private javax.ws.rs.core.MediaType mediaType;
descriptor: Ljavax/ws/rs/core/MediaType;
flags: (0x0002) ACC_PRIVATE
private final java.io.InputStream inputStream;
descriptor: Ljava/io/InputStream;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.annotation.Annotation[] annotations;
descriptor: [Ljava/lang/annotation/Annotation;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final javax.ws.rs.core.MultivaluedMap<java.lang.String, java.lang.String> ;
descriptor: Ljavax/ws/rs/core/MultivaluedMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljavax/ws/rs/core/MultivaluedMap<Ljava/lang/String;Ljava/lang/String;>;
private final org.glassfish.jersey.message.MessageBodyWorkers messageBodyWorkers;
descriptor: Lorg/glassfish/jersey/message/MessageBodyWorkers;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.glassfish.jersey.internal.PropertiesDelegate propertiesDelegate;
descriptor: Lorg/glassfish/jersey/internal/PropertiesDelegate;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/glassfish/jersey/client/ChunkedInput;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokestatic java.util.logging.Logger.getLogger:(Ljava/lang/String;)Ljava/util/logging/Logger;
putstatic org.glassfish.jersey.client.ChunkedInput.LOGGER:Ljava/util/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public static org.glassfish.jersey.client.ChunkParser createParser(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/glassfish/jersey/client/ChunkParser;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new org.glassfish.jersey.client.ChunkedInput$FixedBoundaryParser
dup
aload 0
invokevirtual java.lang.String.getBytes:()[B
invokespecial org.glassfish.jersey.client.ChunkedInput$FixedBoundaryParser.<init>:([B)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 boundary Ljava/lang/String;
MethodParameters:
Name Flags
boundary final
public static org.glassfish.jersey.client.ChunkParser createParser(byte[]);
descriptor: ([B)Lorg/glassfish/jersey/client/ChunkParser;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new org.glassfish.jersey.client.ChunkedInput$FixedBoundaryParser
dup
aload 0
invokespecial org.glassfish.jersey.client.ChunkedInput$FixedBoundaryParser.<init>:([B)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 boundary [B
MethodParameters:
Name Flags
boundary final
public static org.glassfish.jersey.client.ChunkParser createMultiParser(java.lang.String[]);
descriptor: ([Ljava/lang/String;)Lorg/glassfish/jersey/client/ChunkParser;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=3, locals=1, args_size=1
start local 0 0: new org.glassfish.jersey.client.ChunkedInput$FixedMultiBoundaryParser
dup
aload 0
invokespecial org.glassfish.jersey.client.ChunkedInput$FixedMultiBoundaryParser.<init>:([Ljava/lang/String;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 boundaries [Ljava/lang/String;
MethodParameters:
Name Flags
boundaries final
protected void <init>(java.lang.reflect.Type, java.io.InputStream, java.lang.annotation.Annotation[], javax.ws.rs.core.MediaType, javax.ws.rs.core.MultivaluedMap<java.lang.String, java.lang.String>, org.glassfish.jersey.message.MessageBodyWorkers, org.glassfish.jersey.internal.PropertiesDelegate);
descriptor: (Ljava/lang/reflect/Type;Ljava/io/InputStream;[Ljava/lang/annotation/Annotation;Ljavax/ws/rs/core/MediaType;Ljavax/ws/rs/core/MultivaluedMap;Lorg/glassfish/jersey/message/MessageBodyWorkers;Lorg/glassfish/jersey/internal/PropertiesDelegate;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=8, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
aload 1
invokespecial javax.ws.rs.core.GenericType.<init>:(Ljava/lang/reflect/Type;)V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield org.glassfish.jersey.client.ChunkedInput.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
ldc "\r\n"
invokestatic org.glassfish.jersey.client.ChunkedInput.createParser:(Ljava/lang/String;)Lorg/glassfish/jersey/client/ChunkParser;
putfield org.glassfish.jersey.client.ChunkedInput.parser:Lorg/glassfish/jersey/client/ChunkParser;
3: aload 0
aload 2
putfield org.glassfish.jersey.client.ChunkedInput.inputStream:Ljava/io/InputStream;
4: aload 0
aload 3
putfield org.glassfish.jersey.client.ChunkedInput.annotations:[Ljava/lang/annotation/Annotation;
5: aload 0
aload 4
putfield org.glassfish.jersey.client.ChunkedInput.mediaType:Ljavax/ws/rs/core/MediaType;
6: aload 0
aload 5
putfield org.glassfish.jersey.client.ChunkedInput.headers:Ljavax/ws/rs/core/MultivaluedMap;
7: aload 0
aload 6
putfield org.glassfish.jersey.client.ChunkedInput.messageBodyWorkers:Lorg/glassfish/jersey/message/MessageBodyWorkers;
8: aload 0
aload 7
putfield org.glassfish.jersey.client.ChunkedInput.propertiesDelegate:Lorg/glassfish/jersey/internal/PropertiesDelegate;
9: return
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
0 10 1 chunkType Ljava/lang/reflect/Type;
0 10 2 inputStream Ljava/io/InputStream;
0 10 3 annotations [Ljava/lang/annotation/Annotation;
0 10 4 mediaType Ljavax/ws/rs/core/MediaType;
0 10 5 headers Ljavax/ws/rs/core/MultivaluedMap<Ljava/lang/String;Ljava/lang/String;>;
0 10 6 messageBodyWorkers Lorg/glassfish/jersey/message/MessageBodyWorkers;
0 10 7 propertiesDelegate Lorg/glassfish/jersey/internal/PropertiesDelegate;
Signature: (Ljava/lang/reflect/Type;Ljava/io/InputStream;[Ljava/lang/annotation/Annotation;Ljavax/ws/rs/core/MediaType;Ljavax/ws/rs/core/MultivaluedMap<Ljava/lang/String;Ljava/lang/String;>;Lorg/glassfish/jersey/message/MessageBodyWorkers;Lorg/glassfish/jersey/internal/PropertiesDelegate;)V
MethodParameters:
Name Flags
chunkType final
inputStream final
annotations final
mediaType final
headers final
messageBodyWorkers final
propertiesDelegate final
public org.glassfish.jersey.client.ChunkParser getParser();
descriptor: ()Lorg/glassfish/jersey/client/ChunkParser;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.parser:Lorg/glassfish/jersey/client/ChunkParser;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
public void setParser(org.glassfish.jersey.client.ChunkParser);
descriptor: (Lorg/glassfish/jersey/client/ChunkParser;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield org.glassfish.jersey.client.ChunkedInput.parser:Lorg/glassfish/jersey/client/ChunkParser;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
0 2 1 parser Lorg/glassfish/jersey/client/ChunkParser;
MethodParameters:
Name Flags
parser final
public javax.ws.rs.core.MediaType getChunkType();
descriptor: ()Ljavax/ws/rs/core/MediaType;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.mediaType:Ljavax/ws/rs/core/MediaType;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
public void setChunkType(javax.ws.rs.core.MediaType);
descriptor: (Ljavax/ws/rs/core/MediaType;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 2
1: new java.lang.IllegalArgumentException
dup
invokestatic org.glassfish.jersey.client.internal.LocalizationMessages.CHUNKED_INPUT_MEDIA_TYPE_NULL:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield org.glassfish.jersey.client.ChunkedInput.mediaType:Ljavax/ws/rs/core/MediaType;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
0 4 1 mediaType Ljavax/ws/rs/core/MediaType;
Exceptions:
throws java.lang.IllegalArgumentException
MethodParameters:
Name Flags
mediaType final
public void setChunkType(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic javax.ws.rs.core.MediaType.valueOf:(Ljava/lang/String;)Ljavax/ws/rs/core/MediaType;
putfield org.glassfish.jersey.client.ChunkedInput.mediaType:Ljavax/ws/rs/core/MediaType;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
0 2 1 mediaType Ljava/lang/String;
Exceptions:
throws java.lang.IllegalArgumentException
MethodParameters:
Name Flags
mediaType final
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 6
1: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.inputStream:Ljava/io/InputStream;
ifnull 6
2: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.inputStream:Ljava/io/InputStream;
invokevirtual java.io.InputStream.close:()V
3: goto 6
StackMap locals:
StackMap stack: java.io.IOException
4: astore 1
start local 1 5: getstatic org.glassfish.jersey.client.ChunkedInput.LOGGER:Ljava/util/logging/Logger;
getstatic java.util.logging.Level.FINE:Ljava/util/logging/Level;
invokestatic org.glassfish.jersey.client.internal.LocalizationMessages.CHUNKED_INPUT_STREAM_CLOSING_ERROR:()Ljava/lang/String;
aload 1
invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
end local 1 6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
5 6 1 e Ljava/io/IOException;
Exception table:
from to target type
2 3 4 Class java.io.IOException
public boolean isClosed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
public T read();
descriptor: ()Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=3, args_size=1
start local 0 0: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 2
1: new java.lang.IllegalStateException
dup
invokestatic org.glassfish.jersey.client.internal.LocalizationMessages.CHUNKED_INPUT_CLOSED:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.jersey.client.ChunkedInput.parser:Lorg/glassfish/jersey/client/ChunkParser;
aload 0
getfield org.glassfish.jersey.client.ChunkedInput.inputStream:Ljava/io/InputStream;
invokeinterface org.glassfish.jersey.client.ChunkParser.readChunk:(Ljava/io/InputStream;)[B
astore 1
start local 1 3: aload 1
ifnonnull 6
4: aload 0
invokevirtual org.glassfish.jersey.client.ChunkedInput.close:()V
5: goto 22
6: StackMap locals: byte[]
StackMap stack:
new java.io.ByteArrayInputStream
dup
aload 1
invokespecial java.io.ByteArrayInputStream.<init>:([B)V
astore 2
start local 2 7: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.messageBodyWorkers:Lorg/glassfish/jersey/message/MessageBodyWorkers;
8: aload 0
invokevirtual org.glassfish.jersey.client.ChunkedInput.getRawType:()Ljava/lang/Class;
9: aload 0
invokevirtual org.glassfish.jersey.client.ChunkedInput.getType:()Ljava/lang/reflect/Type;
10: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.annotations:[Ljava/lang/annotation/Annotation;
11: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.mediaType:Ljavax/ws/rs/core/MediaType;
12: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.headers:Ljavax/ws/rs/core/MultivaluedMap;
13: aload 0
getfield org.glassfish.jersey.client.ChunkedInput.propertiesDelegate:Lorg/glassfish/jersey/internal/PropertiesDelegate;
14: aload 2
15: invokestatic java.util.Collections.emptyList:()Ljava/util/List;
16: iconst_0
17: invokeinterface org.glassfish.jersey.message.MessageBodyWorkers.readFrom:(Ljava/lang/Class;Ljava/lang/reflect/Type;[Ljava/lang/annotation/Annotation;Ljavax/ws/rs/core/MediaType;Ljavax/ws/rs/core/MultivaluedMap;Lorg/glassfish/jersey/internal/PropertiesDelegate;Ljava/io/InputStream;Ljava/lang/Iterable;Z)Ljava/lang/Object;
18: areturn
end local 2 end local 1 19: StackMap locals: org.glassfish.jersey.client.ChunkedInput
StackMap stack: java.io.IOException
astore 1
start local 1 20: aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokestatic java.util.logging.Logger.getLogger:(Ljava/lang/String;)Ljava/util/logging/Logger;
getstatic java.util.logging.Level.FINE:Ljava/util/logging/Level;
aload 1
invokevirtual java.io.IOException.getMessage:()Ljava/lang/String;
aload 1
invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
21: aload 0
invokevirtual org.glassfish.jersey.client.ChunkedInput.close:()V
end local 1 22: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/glassfish/jersey/client/ChunkedInput<TT;>;
3 19 1 chunk [B
7 19 2 chunkStream Ljava/io/ByteArrayInputStream;
20 22 1 e Ljava/io/IOException;
Exception table:
from to target type
2 18 19 Class java.io.IOException
Exceptions:
throws java.lang.IllegalStateException
Signature: ()TT;
}
Signature: <T:Ljava/lang/Object;>Ljavax/ws/rs/core/GenericType<TT;>;Ljava/io/Closeable;
SourceFile: "ChunkedInput.java"
NestMembers:
org.glassfish.jersey.client.ChunkedInput$AbstractBoundaryParser org.glassfish.jersey.client.ChunkedInput$FixedBoundaryParser org.glassfish.jersey.client.ChunkedInput$FixedMultiBoundaryParser org.glassfish.jersey.client.ChunkedInput$FixedMultiBoundaryParser$1
InnerClasses:
private abstract AbstractBoundaryParser = org.glassfish.jersey.client.ChunkedInput$AbstractBoundaryParser of org.glassfish.jersey.client.ChunkedInput
private FixedBoundaryParser = org.glassfish.jersey.client.ChunkedInput$FixedBoundaryParser of org.glassfish.jersey.client.ChunkedInput
private FixedMultiBoundaryParser = org.glassfish.jersey.client.ChunkedInput$FixedMultiBoundaryParser of org.glassfish.jersey.client.ChunkedInput