public class io.vertx.core.http.impl.HttpClientRequestImpl extends io.vertx.core.http.impl.HttpClientRequestBase implements io.vertx.core.http.HttpClientRequest
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.http.impl.HttpClientRequestImpl
super_class: io.vertx.core.http.impl.HttpClientRequestBase
{
static final io.vertx.core.logging.Logger log;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x0018) ACC_STATIC, ACC_FINAL
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean chunked;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private java.lang.String ;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String rawMethod;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<java.lang.Void> continueHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
private io.vertx.core.Handler<java.lang.Void> drainHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
private io.vertx.core.Handler<io.vertx.core.http.HttpClientRequest> pushHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientRequest;>;
private io.vertx.core.Handler<io.vertx.core.http.HttpConnection> connectionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;
private io.vertx.core.Handler<java.lang.Throwable> exceptionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
private io.vertx.core.Promise<java.lang.Void> endPromise;
descriptor: Lio/vertx/core/Promise;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Promise<Ljava/lang/Void;>;
private io.vertx.core.Future<java.lang.Void> endFuture;
descriptor: Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Future<Ljava/lang/Void;>;
private boolean ended;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private java.lang.Throwable reset;
descriptor: Ljava/lang/Throwable;
flags: (0x0002) ACC_PRIVATE
private io.netty.buffer.ByteBuf pendingChunks;
descriptor: Lio/netty/buffer/ByteBuf;
flags: (0x0002) ACC_PRIVATE
private java.util.List<io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>> pendingHandlers;
descriptor: Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/List<Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;>;
private int pendingMaxSize;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int followRedirects;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.impl.headers.VertxHttpHeaders ;
descriptor: Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.StreamPriority priority;
descriptor: Lio/vertx/core/http/StreamPriority;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.impl.HttpClientStream stream;
descriptor: Lio/vertx/core/http/impl/HttpClientStream;
flags: (0x0002) ACC_PRIVATE
private boolean connecting;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<io.vertx.core.http.HttpClientResponse> respHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientResponse;>;
private io.vertx.core.Handler<java.lang.Void> endHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/core/http/impl/HttpClientRequestImpl;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.core.http.impl.HttpClientRequestImpl.log:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(io.vertx.core.http.impl.HttpClientImpl, boolean, io.vertx.core.http.HttpMethod, io.vertx.core.net.SocketAddress, java.lang.String, int, java.lang.String, io.vertx.core.impl.VertxInternal);
descriptor: (Lio/vertx/core/http/impl/HttpClientImpl;ZLio/vertx/core/http/HttpMethod;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;ILjava/lang/String;Lio/vertx/core/impl/VertxInternal;)V
flags: (0x0000)
Code:
stack=8, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
aload 1
iload 2
aload 3
aload 4
aload 5
iload 6
aload 7
invokespecial io.vertx.core.http.impl.HttpClientRequestBase.<init>:(Lio/vertx/core/http/impl/HttpClientImpl;ZLio/vertx/core/http/HttpMethod;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;ILjava/lang/String;)V
1: aload 0
invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
putfield io.vertx.core.http.impl.HttpClientRequestImpl.endPromise:Lio/vertx/core/Promise;
2: aload 0
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endPromise:Lio/vertx/core/Promise;
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
putfield io.vertx.core.http.impl.HttpClientRequestImpl.endFuture:Lio/vertx/core/Future;
3: aload 0
iconst_m1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingMaxSize:I
4: aload 0
iconst_0
putfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
5: aload 0
aload 8
putfield io.vertx.core.http.impl.HttpClientRequestImpl.vertx:Lio/vertx/core/impl/VertxInternal;
6: aload 0
getstatic io.vertx.core.http.impl.HttpUtils.DEFAULT_STREAM_PRIORITY:Lio/vertx/core/http/StreamPriority;
putfield io.vertx.core.http.impl.HttpClientRequestImpl.priority:Lio/vertx/core/http/StreamPriority;
7: return
end local 8 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 8 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 8 1 client Lio/vertx/core/http/impl/HttpClientImpl;
0 8 2 ssl Z
0 8 3 method Lio/vertx/core/http/HttpMethod;
0 8 4 server Lio/vertx/core/net/SocketAddress;
0 8 5 host Ljava/lang/String;
0 8 6 port I
0 8 7 relativeURI Ljava/lang/String;
0 8 8 vertx Lio/vertx/core/impl/VertxInternal;
MethodParameters:
Name Flags
client
ssl
method
server
host
port
relativeURI
vertx
public synchronized int streamId();
descriptor: ()I
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
ifnonnull 1
iconst_m1
goto 2
StackMap locals:
StackMap stack:
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
invokeinterface io.vertx.core.http.impl.HttpClientStream.id:()I
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public synchronized io.vertx.core.http.HttpClientRequest handler(io.vertx.core.Handler<io.vertx.core.http.HttpClientResponse>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.respHandler:Lio/vertx/core/Handler;
3: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 4 1 handler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientResponse;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientResponse;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
handler
public io.vertx.core.http.HttpClientRequest setFollowRedirects(boolean);
descriptor: (Z)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: iload 1
ifeq 5
3: aload 0
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getMaxRedirects:()I
iconst_1
isub
putfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
4: goto 6
5: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 0
iconst_0
putfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
6: StackMap locals:
StackMap stack:
aload 0
aload 2
monitorexit
7: areturn
8: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
9: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 10 1 followRedirects Z
Exception table:
from to target type
1 7 8 any
8 9 8 any
MethodParameters:
Name Flags
followRedirects
public io.vertx.core.http.HttpClientRequest setMaxRedirects(int);
descriptor: (I)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: iload 1
iflt 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ldc "Max redirects must be >= 0"
invokestatic io.vertx.core.impl.Arguments.require:(ZLjava/lang/String;)V
3: aload 0
dup
astore 2
monitorenter
4: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
5: aload 0
iload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
6: aload 0
aload 2
monitorexit
7: areturn
8: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl int io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
aload 2
monitorexit
9: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 10 1 maxRedirects I
Exception table:
from to target type
4 7 8 any
8 9 8 any
MethodParameters:
Name Flags
maxRedirects
public io.vertx.core.http.HttpClientRequest endHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 1
ifnull 3
2: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
3: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.endHandler:Lio/vertx/core/Handler;
4: aload 0
aload 2
monitorexit
5: areturn
6: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
7: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 8 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Exception table:
from to target type
1 5 6 any
6 7 6 any
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
handler
public io.vertx.core.http.impl.HttpClientRequestImpl setChunked(boolean);
descriptor: (Z)Lio/vertx/core/http/impl/HttpClientRequestImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
ifnull 4
3: new java.lang.IllegalStateException
dup
ldc "Cannot set chunked after data has been written on request"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getProtocolVersion:()Lio/vertx/core/http/HttpVersion;
getstatic io.vertx.core.http.HttpVersion.HTTP_1_0:Lio/vertx/core/http/HttpVersion;
if_acmpeq 6
5: aload 0
iload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
6: StackMap locals:
StackMap stack:
aload 0
aload 2
monitorexit
7: areturn
8: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
9: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 10 1 chunked Z
Exception table:
from to target type
1 7 8 any
8 9 8 any
MethodParameters:
Name Flags
chunked
public synchronized boolean isChunked();
descriptor: ()Z
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public synchronized java.lang.String getRawMethod();
descriptor: ()Ljava/lang/String;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.rawMethod:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public synchronized io.vertx.core.http.HttpClientRequest setRawMethod(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.rawMethod:Ljava/lang/String;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 method Ljava/lang/String;
MethodParameters:
Name Flags
method
public synchronized io.vertx.core.http.HttpClientRequest setHost(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 host Ljava/lang/String;
MethodParameters:
Name Flags
host
public synchronized java.lang.String getHost();
descriptor: ()Ljava/lang/String;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public synchronized io.vertx.core.MultiMap ();
descriptor: ()Lio/vertx/core/MultiMap;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
ifnonnull 2
1: aload 0
new io.vertx.core.http.impl.headers.VertxHttpHeaders
dup
invokespecial io.vertx.core.http.impl.headers.VertxHttpHeaders.<init>:()V
putfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public synchronized io.vertx.core.http.HttpClientRequest (java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.headers:()Lio/vertx/core/MultiMap;
aload 1
aload 2
invokeinterface io.vertx.core.MultiMap.set:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/MultiMap;
pop
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 name Ljava/lang/String;
0 3 2 value Ljava/lang/String;
MethodParameters:
Name Flags
name
value
public synchronized io.vertx.core.http.HttpClientRequest putHeader(java.lang.String, java.lang.Iterable<java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/lang/Iterable;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.headers:()Lio/vertx/core/MultiMap;
aload 1
aload 2
invokeinterface io.vertx.core.MultiMap.set:(Ljava/lang/String;Ljava/lang/Iterable;)Lio/vertx/core/MultiMap;
pop
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 name Ljava/lang/String;
0 3 2 values Ljava/lang/Iterable<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Ljava/lang/Iterable<Ljava/lang/String;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
name
values
public io.vertx.core.http.HttpClientRequest setWriteQueueMaxSize(int);
descriptor: (I)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
dup
astore 2
start local 2 3: ifnonnull 7
4: aload 0
iload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingMaxSize:I
5: aload 0
aload 3
monitorexit
6: areturn
7: StackMap locals: io.vertx.core.http.impl.HttpClientStream io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 3
monitorexit
8: goto 11
end local 2 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl int top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
9: aload 3
monitorexit
10: athrow
start local 2 11: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl int io.vertx.core.http.impl.HttpClientStream
StackMap stack:
aload 2
iload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.doSetWriteQueueMaxSize:(I)V
12: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 13 1 maxSize I
3 9 2 s Lio/vertx/core/http/impl/HttpClientStream;
11 13 2 s Lio/vertx/core/http/impl/HttpClientStream;
Exception table:
from to target type
1 6 9 any
7 8 9 any
9 10 9 any
MethodParameters:
Name Flags
maxSize
public boolean writeQueueFull();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
dup
astore 2
monitorenter
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
dup
astore 1
start local 1 3: ifnonnull 6
4: aload 2
monitorexit
5: iconst_0
ireturn
6: StackMap locals: io.vertx.core.http.impl.HttpClientStream io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 2
monitorexit
7: goto 10
end local 1 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
8: aload 2
monitorexit
9: athrow
start local 1 10: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.http.impl.HttpClientStream
StackMap stack:
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.isNotWritable:()Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
3 8 1 s Lio/vertx/core/http/impl/HttpClientStream;
10 11 1 s Lio/vertx/core/http/impl/HttpClientStream;
Exception table:
from to target type
1 5 8 any
6 7 8 any
8 9 8 any
public io.vertx.core.http.HttpClientRequest drainHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 1
ifnull 10
2: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
3: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.drainHandler:Lio/vertx/core/Handler;
4: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
dup
astore 3
start local 3 5: ifnonnull 8
6: aload 0
aload 2
monitorexit
7: areturn
8: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.http.impl.HttpClientStream
StackMap stack:
aload 3
invokeinterface io.vertx.core.http.impl.HttpClientStream.getContext:()Lio/vertx/core/Context;
aload 0
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$0(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
end local 3 9: goto 11
10: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.vertx.core.http.impl.HttpClientRequestImpl.drainHandler:Lio/vertx/core/Handler;
11: StackMap locals:
StackMap stack:
aload 0
aload 2
monitorexit
12: areturn
13: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
14: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 15 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
5 9 3 s Lio/vertx/core/http/impl/HttpClientStream;
Exception table:
from to target type
1 7 13 any
8 12 13 any
13 14 13 any
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.core.http.HttpClientRequest continueHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.continueHandler:Lio/vertx/core/Handler;
3: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 4 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
handler
public io.vertx.core.http.HttpClientRequest sendHead();
descriptor: ()Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.sendHead:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public synchronized io.vertx.core.http.HttpClientRequest sendHead(io.vertx.core.Handler<io.vertx.core.http.HttpVersion>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkResponseHandler:()V
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
ifnull 4
3: new java.lang.IllegalStateException
dup
ldc "Head already written"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.connect:(Lio/vertx/core/Handler;)V
5: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 6 1 headersHandler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpVersion;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpVersion;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
headersHandler
public synchronized io.vertx.core.http.HttpClientRequest (java.lang.CharSequence, java.lang.CharSequence);
descriptor: (Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.headers:()Lio/vertx/core/MultiMap;
aload 1
aload 2
invokeinterface io.vertx.core.MultiMap.set:(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Lio/vertx/core/MultiMap;
pop
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 name Ljava/lang/CharSequence;
0 3 2 value Ljava/lang/CharSequence;
MethodParameters:
Name Flags
name
value
public synchronized io.vertx.core.http.HttpClientRequest putHeader(java.lang.CharSequence, java.lang.Iterable<java.lang.CharSequence>);
descriptor: (Ljava/lang/CharSequence;Ljava/lang/Iterable;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.headers:()Lio/vertx/core/MultiMap;
aload 1
aload 2
invokeinterface io.vertx.core.MultiMap.set:(Ljava/lang/CharSequence;Ljava/lang/Iterable;)Lio/vertx/core/MultiMap;
pop
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 name Ljava/lang/CharSequence;
0 3 2 values Ljava/lang/Iterable<Ljava/lang/CharSequence;>;
Signature: (Ljava/lang/CharSequence;Ljava/lang/Iterable<Ljava/lang/CharSequence;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
name
values
public synchronized io.vertx.core.http.HttpClientRequest pushHandler(io.vertx.core.Handler<io.vertx.core.http.HttpClientRequest>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pushHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientRequest;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientRequest;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
handler
boolean reset(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x0000)
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.reset:Ljava/lang/Throwable;
ifnull 4
2: aload 3
monitorexit
3: iconst_0
ireturn
4: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl java.lang.Throwable top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.reset:Ljava/lang/Throwable;
5: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
astore 2
start local 2 6: aload 3
monitorexit
7: goto 10
end local 2 StackMap locals:
StackMap stack: java.lang.Throwable
8: aload 3
monitorexit
9: athrow
start local 2 10: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl java.lang.Throwable io.vertx.core.http.impl.HttpClientStream
StackMap stack:
aload 2
ifnull 13
11: aload 2
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.reset:(Ljava/lang/Throwable;)V
12: goto 14
13: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleException:(Ljava/lang/Throwable;)V
14: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 15 1 cause Ljava/lang/Throwable;
6 8 2 s Lio/vertx/core/http/impl/HttpClientStream;
10 15 2 s Lio/vertx/core/http/impl/HttpClientStream;
Exception table:
from to target type
1 3 8 any
4 7 8 any
8 9 8 any
MethodParameters:
Name Flags
cause
private void tryComplete();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endPromise:Lio/vertx/core/Promise;
invokeinterface io.vertx.core.Promise.tryComplete:()Z
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public io.vertx.core.http.HttpConnection connection();
descriptor: ()Lio/vertx/core/http/HttpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
dup
astore 1
start local 1 2: ifnonnull 5
3: aload 2
monitorexit
4: aconst_null
areturn
5: StackMap locals: io.vertx.core.http.impl.HttpClientStream io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 2
monitorexit
6: goto 9
end local 1 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
7: aload 2
monitorexit
8: athrow
start local 1 9: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.http.impl.HttpClientStream
StackMap stack:
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.connection:()Lio/vertx/core/http/HttpConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
2 7 1 s Lio/vertx/core/http/impl/HttpClientStream;
9 10 1 s Lio/vertx/core/http/impl/HttpClientStream;
Exception table:
from to target type
1 4 7 any
5 6 7 any
7 8 7 any
public synchronized io.vertx.core.http.HttpClientRequest connectionHandler(io.vertx.core.Handler<io.vertx.core.http.HttpConnection>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.connectionHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;)Lio/vertx/core/http/HttpClientRequest;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
handler
public synchronized io.vertx.core.http.HttpClientRequest writeCustomFrame(int, int, io.vertx.core.buffer.Buffer);
descriptor: (IILio/vertx/core/buffer/Buffer;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=4, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
dup
astore 5
monitorenter
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
dup
astore 4
start local 4 3: ifnonnull 5
4: new java.lang.IllegalStateException
dup
ldc "Not yet connected"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
5: StackMap locals: io.vertx.core.http.impl.HttpClientStream io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 5
monitorexit
6: goto 9
end local 4 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl int int io.vertx.core.buffer.Buffer top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
7: aload 5
monitorexit
8: athrow
start local 4 9: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl int int io.vertx.core.buffer.Buffer io.vertx.core.http.impl.HttpClientStream
StackMap stack:
aload 4
iload 1
iload 2
aload 3
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
invokeinterface io.vertx.core.http.impl.HttpClientStream.writeFrame:(IILio/netty/buffer/ByteBuf;)V
10: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 11 1 type I
0 11 2 flags I
0 11 3 payload Lio/vertx/core/buffer/Buffer;
3 7 4 s Lio/vertx/core/http/impl/HttpClientStream;
9 11 4 s Lio/vertx/core/http/impl/HttpClientStream;
Exception table:
from to target type
1 6 7 any
7 8 7 any
MethodParameters:
Name Flags
type
flags
payload
void handleDrained();
descriptor: ()V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.drainHandler:Lio/vertx/core/Handler;
dup
astore 1
start local 1 2: ifnull 3
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endFuture:Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.isComplete:()Z
ifeq 5
3: StackMap locals: io.vertx.core.Handler io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 2
monitorexit
4: return
5: StackMap locals:
StackMap stack:
aload 2
monitorexit
6: goto 9
end local 1 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
7: aload 2
monitorexit
8: athrow
start local 1 9: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.Handler
StackMap stack:
aload 1
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
10: goto 13
StackMap locals:
StackMap stack: java.lang.Throwable
11: astore 2
start local 2 12: aload 0
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleException:(Ljava/lang/Throwable;)V
end local 2 13: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
2 7 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
9 14 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
12 13 2 t Ljava/lang/Throwable;
Exception table:
from to target type
1 4 7 any
5 6 7 any
7 8 7 any
9 10 11 Class java.lang.Throwable
private void handleNextRequest(io.vertx.core.http.HttpClientRequest, long);
descriptor: (Lio/vertx/core/http/HttpClientRequest;J)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.respHandler:Lio/vertx/core/Handler;
invokeinterface io.vertx.core.http.HttpClientRequest.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
pop
1: aload 1
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.exceptionHandler:()Lio/vertx/core/Handler;
invokeinterface io.vertx.core.http.HttpClientRequest.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
pop
2: aload 0
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
pop
3: aload 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endHandler:Lio/vertx/core/Handler;
invokeinterface io.vertx.core.http.HttpClientRequest.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
pop
4: aload 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pushHandler:Lio/vertx/core/Handler;
invokeinterface io.vertx.core.http.HttpClientRequest.pushHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
pop
5: aload 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
iconst_1
isub
invokeinterface io.vertx.core.http.HttpClientRequest.setMaxRedirects:(I)Lio/vertx/core/http/HttpClientRequest;
pop
6: aload 1
invokeinterface io.vertx.core.http.HttpClientRequest.getHost:()Ljava/lang/String;
ifnonnull 8
7: aload 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
invokeinterface io.vertx.core.http.HttpClientRequest.setHost:(Ljava/lang/String;)Lio/vertx/core/http/HttpClientRequest;
pop
8: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
ifnull 10
9: aload 1
invokeinterface io.vertx.core.http.HttpClientRequest.headers:()Lio/vertx/core/MultiMap;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
invokeinterface io.vertx.core.MultiMap.addAll:(Lio/vertx/core/MultiMap;)Lio/vertx/core/MultiMap;
pop
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endFuture:Lio/vertx/core/Future;
lload 2
aload 1
invokedynamic handle(JLio/vertx/core/http/HttpClientRequest;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$1(JLio/vertx/core/http/HttpClientRequest;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
11: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 12 1 next Lio/vertx/core/http/HttpClientRequest;
0 12 2 timeoutMs J
MethodParameters:
Name Flags
next
timeoutMs
public void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.HttpClientRequestBase.handleException:(Ljava/lang/Throwable;)V
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endPromise:Lio/vertx/core/Promise;
aload 1
invokeinterface io.vertx.core.Promise.tryFail:(Ljava/lang/Throwable;)Z
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
void handleResponse(io.vertx.core.http.HttpClientResponse, long);
descriptor: (Lio/vertx/core/http/HttpClientResponse;J)V
flags: (0x0000)
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.reset:Ljava/lang/Throwable;
ifnonnull 11
1: aload 1
invokeinterface io.vertx.core.http.HttpClientResponse.statusCode:()I
istore 4
start local 4 2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
ifle 7
iload 4
sipush 300
if_icmplt 7
iload 4
sipush 400
if_icmpge 7
3: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.redirectHandler:()Ljava/util/function/Function;
aload 1
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.Future
astore 5
start local 5 4: aload 5
ifnull 7
5: aload 5
aload 0
lload 2
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestImpl;J)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$2(JLio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
6: return
end local 5 7: StackMap locals: int
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.respHandler:Lio/vertx/core/Handler;
ifnull 9
8: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.respHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
9: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endHandler:Lio/vertx/core/Handler;
ifnull 11
10: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endHandler:Lio/vertx/core/Handler;
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 4 11: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 12 1 resp Lio/vertx/core/http/HttpClientResponse;
0 12 2 timeoutMs J
2 11 4 statusCode I
4 7 5 next Lio/vertx/core/Future<Lio/vertx/core/http/HttpClientRequest;>;
MethodParameters:
Name Flags
resp
timeoutMs
protected java.lang.String ();
descriptor: ()Ljava/lang/String;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
ifnull 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
goto 2
StackMap locals:
StackMap stack:
1: aload 0
invokespecial io.vertx.core.http.impl.HttpClientRequestBase.hostHeader:()Ljava/lang/String;
StackMap locals:
StackMap stack: java.lang.String
2: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
private synchronized void connect(io.vertx.core.Handler<io.vertx.core.http.HttpVersion>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=9, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.connecting:Z
ifne 23
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.method:Lio/vertx/core/http/HttpMethod;
getstatic io.vertx.core.http.HttpMethod.OTHER:Lio/vertx/core/http/HttpMethod;
if_acmpne 3
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.rawMethod:Ljava/lang/String;
ifnonnull 3
2: new java.lang.IllegalStateException
dup
ldc "You must provide a rawMethod when using an HttpMethod.OTHER method"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
ifnull 10
4: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
bipush 58
invokevirtual java.lang.String.lastIndexOf:(I)I
istore 3
start local 3 5: iload 3
iconst_m1
if_icmpeq 8
6: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
iload 3
iconst_1
iadd
invokevirtual java.lang.String.substring:(I)Ljava/lang/String;
invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
iconst_0
iload 3
invokevirtual java.lang.String.substring:(II)Ljava/lang/String;
invokestatic io.vertx.core.net.SocketAddress.inetSocketAddress:(ILjava/lang/String;)Lio/vertx/core/net/SocketAddress;
astore 2
start local 2 7: goto 11
end local 2 8: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.Handler top int
StackMap stack:
bipush 80
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:Ljava/lang/String;
invokestatic io.vertx.core.net.SocketAddress.inetSocketAddress:(ILjava/lang/String;)Lio/vertx/core/net/SocketAddress;
astore 2
end local 3 start local 2 9: goto 11
end local 2 10: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.Handler
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.port:I
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.host:Ljava/lang/String;
invokestatic io.vertx.core.net.SocketAddress.inetSocketAddress:(ILjava/lang/String;)Lio/vertx/core/net/SocketAddress;
astore 2
start local 2 11: StackMap locals: io.vertx.core.net.SocketAddress
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.connectionHandler:Lio/vertx/core/Handler;
astore 3
start local 3 12: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.connectionHandler:()Lio/vertx/core/Handler;
astore 4
start local 4 13: aload 3
ifnull 19
14: aload 4
ifnull 17
15: aload 3
aload 4
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$3(Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/http/HttpConnection;)V (6)
(Lio/vertx/core/http/HttpConnection;)V
astore 5
start local 5 16: goto 20
end local 5 17: StackMap locals: io.vertx.core.Handler io.vertx.core.Handler
StackMap stack:
aload 3
astore 5
start local 5 18: goto 20
end local 5 19: StackMap locals:
StackMap stack:
aload 4
astore 5
start local 5 20: StackMap locals: io.vertx.core.Handler
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 6
start local 6 21: aload 0
iconst_1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.connecting:Z
22: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.client:Lio/vertx/core/http/impl/HttpClientImpl;
aload 6
aload 2
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.ssl:Z
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.server:Lio/vertx/core/net/SocketAddress;
aload 0
aload 5
aload 1
aload 6
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestImpl;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$4(Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getConnectionForRequest:(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/SocketAddress;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/Handler;)V
end local 6 end local 5 end local 4 end local 3 end local 2 23: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.Handler
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 24 1 headersHandler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpVersion;>;
7 8 2 peerAddress Lio/vertx/core/net/SocketAddress;
9 10 2 peerAddress Lio/vertx/core/net/SocketAddress;
11 23 2 peerAddress Lio/vertx/core/net/SocketAddress;
5 9 3 idx I
12 23 3 h1 Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;
13 23 4 h2 Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;
16 17 5 initializer Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;
18 19 5 initializer Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;
20 23 5 initializer Lio/vertx/core/Handler<Lio/vertx/core/http/HttpConnection;>;
21 23 6 connectCtx Lio/vertx/core/impl/ContextInternal;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpVersion;>;)V
MethodParameters:
Name Flags
headersHandler
private void connected(io.vertx.core.Handler<io.vertx.core.http.HttpVersion>, io.vertx.core.http.impl.HttpClientStream);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=12, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 3
monitorenter
1: aload 0
aload 2
putfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
2: aload 2
aload 0
invokeinterface io.vertx.core.http.impl.HttpClientStream.beginRequest:(Lio/vertx/core/http/impl/HttpClientRequestImpl;)V
3: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingMaxSize:I
iconst_m1
if_icmpeq 5
4: aload 2
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingMaxSize:I
invokeinterface io.vertx.core.http.impl.HttpClientStream.doSetWriteQueueMaxSize:(I)V
5: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aconst_null
astore 4
start local 4 6: aconst_null
astore 5
start local 5 7: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
ifnull 14
8: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingHandlers:Ljava/util/List;
astore 6
start local 6 9: aload 0
aconst_null
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingHandlers:Ljava/util/List;
10: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
astore 4
11: aload 0
aconst_null
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
12: aload 6
ifnull 14
13: aload 6
invokedynamic handle(Ljava/util/List;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$8(Ljava/util/List;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
astore 5
end local 6 14: StackMap locals: io.netty.buffer.ByteBuf io.vertx.core.Handler
StackMap stack:
aload 2
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.method:Lio/vertx/core/http/HttpMethod;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.rawMethod:Ljava/lang/String;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.uri:Ljava/lang/String;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.hostHeader:()Ljava/lang/String;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
aload 4
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.ended:Z
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.priority:Lio/vertx/core/http/StreamPriority;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.continueHandler:Lio/vertx/core/Handler;
aload 5
invokeinterface io.vertx.core.http.impl.HttpClientStream.writeHead:(Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/MultiMap;Ljava/lang/String;ZLio/netty/buffer/ByteBuf;ZLio/vertx/core/http/StreamPriority;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
15: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.ended:Z
ifeq 18
16: aload 2
invokeinterface io.vertx.core.http.impl.HttpClientStream.endRequest:()V
17: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.tryComplete:()V
18: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.vertx.core.http.impl.HttpClientRequestImpl.connecting:Z
19: aload 0
aload 2
putfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
end local 5 end local 4 20: aload 3
monitorexit
21: goto 24
StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.Handler io.vertx.core.http.impl.HttpClientStream io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
22: aload 3
monitorexit
23: athrow
24: StackMap locals:
StackMap stack:
aload 1
ifnull 26
25: aload 1
aload 2
invokeinterface io.vertx.core.http.impl.HttpClientStream.version:()Lio/vertx/core/http/HttpVersion;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
26: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 27 1 headersHandler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpVersion;>;
0 27 2 stream Lio/vertx/core/http/impl/HttpClientStream;
6 20 4 pending Lio/netty/buffer/ByteBuf;
7 20 5 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
9 14 6 handlers Ljava/util/List<Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;>;
Exception table:
from to target type
1 21 22 any
22 23 22 any
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpVersion;>;Lio/vertx/core/http/impl/HttpClientStream;)V
MethodParameters:
Name Flags
headersHandler
stream
public void end(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Ljava/lang/String;Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 chunk Ljava/lang/String;
MethodParameters:
Name Flags
chunk
public void end(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 chunk Ljava/lang/String;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
chunk
handler
public void end(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 chunk Ljava/lang/String;
0 2 2 enc Ljava/lang/String;
MethodParameters:
Name Flags
chunk
enc
public void end(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
ldc "no null encoding accepted"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
aload 2
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 chunk Ljava/lang/String;
0 3 2 enc Ljava/lang/String;
0 3 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
chunk
enc
handler
public void end(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
iconst_1
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 chunk Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
chunk
public void end(io.vertx.core.buffer.Buffer, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
iconst_1
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 chunk Lio/vertx/core/buffer/Buffer;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
chunk
handler
public void end();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
iconst_1
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aconst_null
iconst_1
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public io.vertx.core.http.HttpClientRequest write(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 1 1 chunk Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
chunk
public io.vertx.core.http.HttpClientRequest write(io.vertx.core.buffer.Buffer, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
astore 3
start local 3 1: aload 0
aload 3
iconst_0
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
2: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 chunk Lio/vertx/core/buffer/Buffer;
0 3 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 3 buf Lio/netty/buffer/ByteBuf;
Signature: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
chunk
handler
public io.vertx.core.http.HttpClientRequest write(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 1 1 chunk Ljava/lang/String;
MethodParameters:
Name Flags
chunk
public io.vertx.core.http.HttpClientRequest write(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
iconst_0
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 1 chunk Ljava/lang/String;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
chunk
handler
public io.vertx.core.http.HttpClientRequest write(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 1 1 chunk Ljava/lang/String;
0 1 2 enc Ljava/lang/String;
MethodParameters:
Name Flags
chunk
enc
public io.vertx.core.http.HttpClientRequest write(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
ldc "no null encoding accepted"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
aload 2
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
iconst_0
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
2: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 3 1 chunk Ljava/lang/String;
0 3 2 enc Ljava/lang/String;
0 3 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
chunk
enc
handler
private boolean requiresContentLength();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
ifne 2
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
ifnull 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/VertxHttpHeaders;
getstatic io.vertx.core.http.HttpHeaders.CONTENT_LENGTH:Ljava/lang/CharSequence;
invokevirtual io.vertx.core.http.impl.headers.VertxHttpHeaders.contains:(Ljava/lang/CharSequence;)Z
ifne 2
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
StackMap locals:
StackMap stack:
2: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
private void write(io.netty.buffer.ByteBuf, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ifnonnull 2
iload 2
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
dup
astore 5
monitorenter
3: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
4: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkResponseHandler:()V
5: iload 2
ifeq 9
6: aload 1
ifnull 11
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.requiresContentLength:()Z
ifeq 11
7: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.headers:()Lio/vertx/core/MultiMap;
getstatic io.vertx.core.http.HttpHeaders.CONTENT_LENGTH:Ljava/lang/CharSequence;
aload 1
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
invokestatic java.lang.String.valueOf:(I)Ljava/lang/String;
invokeinterface io.vertx.core.MultiMap.set:(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Lio/vertx/core/MultiMap;
pop
8: goto 11
StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.netty.buffer.ByteBuf int io.vertx.core.Handler top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
9: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.requiresContentLength:()Z
ifeq 11
10: new java.lang.IllegalStateException
dup
ldc "You must set the Content-Length header to be the total size of the message body BEFORE sending any data if you are not using HTTP chunked encoding."
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
11: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.vertx.core.http.impl.HttpClientRequestImpl.ended:Z
iload 2
ior
putfield io.vertx.core.http.impl.HttpClientRequestImpl.ended:Z
12: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
ifnonnull 31
13: aload 1
ifnull 28
14: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
ifnonnull 17
15: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
16: goto 24
17: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
instanceof io.netty.buffer.CompositeByteBuf
ifeq 20
18: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
checkcast io.netty.buffer.CompositeByteBuf
astore 6
start local 6 19: goto 23
end local 6 20: StackMap locals:
StackMap stack:
invokestatic io.netty.buffer.Unpooled.compositeBuffer:()Lio/netty/buffer/CompositeByteBuf;
astore 6
start local 6 21: aload 6
iconst_1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.CompositeByteBuf.addComponent:(ZLio/netty/buffer/ByteBuf;)Lio/netty/buffer/CompositeByteBuf;
pop
22: aload 0
aload 6
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingChunks:Lio/netty/buffer/ByteBuf;
23: StackMap locals: io.netty.buffer.CompositeByteBuf
StackMap stack:
aload 6
iconst_1
aload 1
invokevirtual io.netty.buffer.CompositeByteBuf.addComponent:(ZLio/netty/buffer/ByteBuf;)Lio/netty/buffer/CompositeByteBuf;
pop
end local 6 24: StackMap locals:
StackMap stack:
aload 3
ifnull 28
25: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingHandlers:Ljava/util/List;
ifnonnull 27
26: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingHandlers:Ljava/util/List;
27: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pendingHandlers:Ljava/util/List;
aload 3
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
28: StackMap locals:
StackMap stack:
aload 0
aconst_null
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.connect:(Lio/vertx/core/Handler;)V
29: aload 5
monitorexit
30: return
31: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
astore 4
start local 4 32: aload 5
monitorexit
33: goto 36
end local 4 StackMap locals:
StackMap stack: java.lang.Throwable
34: aload 5
monitorexit
35: athrow
start local 4 36: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.netty.buffer.ByteBuf int io.vertx.core.Handler io.vertx.core.http.impl.HttpClientStream
StackMap stack:
aload 4
aload 1
iload 2
aload 3
invokeinterface io.vertx.core.http.impl.HttpClientStream.writeBuffer:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
37: iload 2
ifeq 40
38: aload 4
invokeinterface io.vertx.core.http.impl.HttpClientStream.endRequest:()V
39: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.tryComplete:()V
40: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 41 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 41 1 buff Lio/netty/buffer/ByteBuf;
0 41 2 end Z
0 41 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
32 34 4 s Lio/vertx/core/http/impl/HttpClientStream;
36 41 4 s Lio/vertx/core/http/impl/HttpClientStream;
19 20 6 pending Lio/netty/buffer/CompositeByteBuf;
21 24 6 pending Lio/netty/buffer/CompositeByteBuf;
Exception table:
from to target type
3 30 34 any
31 33 34 any
34 35 34 any
Signature: (Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
buff
end
completionHandler
protected void checkEnded();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.ended:Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "Request already complete"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
private void checkResponseHandler();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.respHandler:Lio/vertx/core/Handler;
ifnonnull 2
1: new java.lang.IllegalStateException
dup
ldc "You must set an handler for the HttpClientResponse before connecting"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
synchronized io.vertx.core.Handler<io.vertx.core.http.HttpClientRequest> pushHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.pushHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
Signature: ()Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientRequest;>;
public synchronized io.vertx.core.http.HttpClientRequest setStreamPriority(io.vertx.core.http.StreamPriority);
descriptor: (Lio/vertx/core/http/StreamPriority;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
ifnull 4
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.updatePriority:(Lio/vertx/core/http/StreamPriority;)V
3: goto 5
4: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.priority:Lio/vertx/core/http/StreamPriority;
5: StackMap locals:
StackMap stack:
aload 2
monitorexit
6: goto 9
StackMap locals:
StackMap stack: java.lang.Throwable
7: aload 2
monitorexit
8: athrow
9: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 10 1 priority Lio/vertx/core/http/StreamPriority;
Exception table:
from to target type
1 6 7 any
7 8 7 any
MethodParameters:
Name Flags
priority
public synchronized io.vertx.core.http.StreamPriority getStreamPriority();
descriptor: ()Lio/vertx/core/http/StreamPriority;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
astore 1
start local 1 1: aload 1
ifnull 2
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.priority:()Lio/vertx/core/http/StreamPriority;
goto 3
StackMap locals: io.vertx.core.http.impl.HttpClientStream
StackMap stack:
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.priority:Lio/vertx/core/http/StreamPriority;
StackMap locals:
StackMap stack: io.vertx.core.http.StreamPriority
3: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
1 4 1 s Lio/vertx/core/http/impl/HttpClientStream;
public io.vertx.core.http.HttpClientRequest setChunked(boolean);
descriptor: (Z)Lio/vertx/core/http/HttpClientRequest;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
iload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.setChunked:(Z)Lio/vertx/core/http/impl/HttpClientRequestImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream write(java.lang.Object, io.vertx.core.Handler);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast io.vertx.core.buffer.Buffer
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream write(java.lang.Object);
descriptor: (Ljava/lang/Object;)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.buffer.Buffer
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/http/HttpClientRequest;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream setWriteQueueMaxSize(int);
descriptor: (I)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
iload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.setWriteQueueMaxSize:(I)Lio/vertx/core/http/HttpClientRequest;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream handler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.Handler
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
LocalVariableTable:
Start End Slot Name Signature
public void end(java.lang.Object, io.vertx.core.Handler);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast io.vertx.core.buffer.Buffer
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
return
LocalVariableTable:
Start End Slot Name Signature
public void end(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.buffer.Buffer
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Lio/vertx/core/buffer/Buffer;)V
return
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream endHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream drainHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$0(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
invokeinterface io.vertx.core.http.impl.HttpClientStream.isNotWritable:()Z
ifne 3
2: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleDrained:()V
3: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 2
monitorexit
4: goto 7
StackMap locals:
StackMap stack: java.lang.Throwable
5: aload 2
monitorexit
6: athrow
7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 8 1 v Ljava/lang/Void;
Exception table:
from to target type
1 4 5 any
5 6 5 any
private static void lambda$1(long, io.vertx.core.http.HttpClientRequest, io.vertx.core.AsyncResult);
descriptor: (JLio/vertx/core/http/HttpClientRequest;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: lload 0
lconst_0
lcmp
ifle 3
2: aload 2
lload 0
invokeinterface io.vertx.core.http.HttpClientRequest.setTimeout:(J)Lio/vertx/core/http/HttpClientRequest;
pop
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.http.HttpClientRequest.end:()V
4: goto 6
5: StackMap locals:
StackMap stack:
aload 2
lconst_0
invokeinterface io.vertx.core.http.HttpClientRequest.reset:(J)Z
pop
6: StackMap locals:
StackMap stack:
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 7 3 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$2(long, io.vertx.core.AsyncResult);
descriptor: (JLio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.http.HttpClientRequest
lload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleNextRequest:(Lio/vertx/core/http/HttpClientRequest;J)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 3
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleException:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 5 3 ar Lio/vertx/core/AsyncResult<Lio/vertx/core/http/HttpClientRequest;>;
private static void lambda$3(io.vertx.core.Handler, io.vertx.core.Handler, io.vertx.core.http.HttpConnection);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/http/HttpConnection;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
1: aload 1
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 conn Lio/vertx/core/http/HttpConnection;
private void lambda$4(io.vertx.core.Handler, io.vertx.core.Handler, io.vertx.core.impl.ContextInternal, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=7, args_size=5
start local 0 start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 10
1: aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.HttpClientStream
astore 5
start local 5 2: aload 5
invokeinterface io.vertx.core.http.impl.HttpClientStream.getContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 6
start local 6 3: aload 5
invokeinterface io.vertx.core.http.impl.HttpClientStream.id:()I
iconst_1
if_icmpne 5
aload 1
ifnull 5
4: aload 6
aload 1
aload 5
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$5(Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeFromIO:(Lio/vertx/core/Handler;)V
5: StackMap locals: io.vertx.core.http.impl.HttpClientStream io.vertx.core.impl.ContextInternal
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.reset:Ljava/lang/Throwable;
ifnull 8
6: aload 5
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.reset:Ljava/lang/Throwable;
invokeinterface io.vertx.core.http.impl.HttpClientStream.reset:(Ljava/lang/Throwable;)V
7: goto 11
8: StackMap locals:
StackMap stack:
aload 6
aload 0
aload 2
aload 5
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestImpl;Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$6(Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeFromIO:(Lio/vertx/core/Handler;)V
end local 6 end local 5 9: goto 11
10: StackMap locals:
StackMap stack:
aload 3
aload 0
aload 4
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestImpl;Lio/vertx/core/AsyncResult;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$7(Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeFromIO:(Lio/vertx/core/Handler;)V
11: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 12 4 ar1 Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;
2 9 5 stream Lio/vertx/core/http/impl/HttpClientStream;
3 9 6 ctx Lio/vertx/core/impl/ContextInternal;
private static void lambda$8(java.util.List, io.vertx.core.AsyncResult);
descriptor: (Ljava/util/List;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokedynamic accept(Lio/vertx/core/AsyncResult;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/HttpClientRequestImpl.lambda$9(Lio/vertx/core/AsyncResult;Lio/vertx/core/Handler;)V (6)
(Lio/vertx/core/Handler;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private static void lambda$5(io.vertx.core.Handler, io.vertx.core.http.impl.HttpClientStream, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.connection:()Lio/vertx/core/http/HttpConnection;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
1: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 2 2 v Ljava/lang/Void;
private void lambda$6(io.vertx.core.Handler, io.vertx.core.http.impl.HttpClientStream, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.connected:(Lio/vertx/core/Handler;Lio/vertx/core/http/impl/HttpClientStream;)V
1: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 3 v Ljava/lang/Void;
private void lambda$7(io.vertx.core.AsyncResult, java.lang.Void);
descriptor: (Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleException:(Ljava/lang/Throwable;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 2 2 v Ljava/lang/Void;
private static void lambda$9(io.vertx.core.AsyncResult, io.vertx.core.Handler);
descriptor: (Lio/vertx/core/AsyncResult;Lio/vertx/core/Handler;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 h Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
}
SourceFile: "HttpClientRequestImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles