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.impl.logging.Logger log;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x0018) ACC_STATIC, ACC_FINAL
private final io.vertx.core.Promise<java.lang.Void> endPromise;
descriptor: Lio/vertx/core/Promise;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/Promise<Ljava/lang/Void;>;
private final io.vertx.core.Future<java.lang.Void> endFuture;
descriptor: Lio/vertx/core/Future;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/Future<Ljava/lang/Void;>;
private boolean chunked;
descriptor: Z
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<java.lang.Throwable> exceptionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
private boolean ended;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private java.lang.Throwable reset;
descriptor: Ljava/lang/Throwable;
flags: (0x0002) ACC_PRIVATE
private int followRedirects;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.impl.headers.HeadersMultiMap ;
descriptor: Lio/vertx/core/http/impl/headers/HeadersMultiMap;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.StreamPriority priority;
descriptor: Lio/vertx/core/http/StreamPriority;
flags: (0x0002) ACC_PRIVATE
private boolean headWritten;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean isConnect;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
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.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.core.http.impl.HttpClientRequestImpl.log:Lio/vertx/core/impl/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(io.vertx.core.http.impl.HttpClientImpl, io.vertx.core.http.impl.HttpClientStream, io.vertx.core.impl.future.PromiseInternal<io.vertx.core.http.HttpClientResponse>, boolean, io.vertx.core.http.HttpMethod, io.vertx.core.net.SocketAddress, java.lang.String, int, java.lang.String);
descriptor: (Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/http/impl/HttpClientStream;Lio/vertx/core/impl/future/PromiseInternal;ZLio/vertx/core/http/HttpMethod;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;ILjava/lang/String;)V
flags: (0x0000)
Code:
stack=10, locals=10, args_size=10
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 start local 9 0: aload 0
aload 1
aload 2
aload 3
iload 4
aload 5
aload 6
aload 7
iload 8
aload 9
invokespecial io.vertx.core.http.impl.HttpClientRequestBase.<init>:(Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/http/impl/HttpClientStream;Lio/vertx/core/impl/future/PromiseInternal;ZLio/vertx/core/http/HttpMethod;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;ILjava/lang/String;)V
1: aload 0
iconst_0
putfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
2: aload 0
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
putfield io.vertx.core.http.impl.HttpClientRequestImpl.endPromise:Lio/vertx/core/Promise;
3: 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;
4: 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;
5: aload 2
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.handleContinue(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.continueHandler:(Lio/vertx/core/Handler;)V
6: aload 2
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.handleDrained(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.drainHandler:(Lio/vertx/core/Handler;)V
7: aload 2
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.handleException(Ljava/lang/Throwable;)V (5)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.exceptionHandler:(Lio/vertx/core/Handler;)V
8: return
end local 9 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 9 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 9 1 client Lio/vertx/core/http/impl/HttpClientImpl;
0 9 2 stream Lio/vertx/core/http/impl/HttpClientStream;
0 9 3 responsePromise Lio/vertx/core/impl/future/PromiseInternal<Lio/vertx/core/http/HttpClientResponse;>;
0 9 4 ssl Z
0 9 5 method Lio/vertx/core/http/HttpMethod;
0 9 6 server Lio/vertx/core/net/SocketAddress;
0 9 7 host Ljava/lang/String;
0 9 8 port I
0 9 9 requestURI Ljava/lang/String;
Signature: (Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/http/impl/HttpClientStream;Lio/vertx/core/impl/future/PromiseInternal<Lio/vertx/core/http/HttpClientResponse;>;ZLio/vertx/core/http/HttpMethod;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;ILjava/lang/String;)V
MethodParameters:
Name Flags
client
stream
responsePromise
ssl
method
server
host
port
requestURI
void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=3, locals=4, 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
dup
astore 3
monitorenter
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.exceptionHandler:Lio/vertx/core/Handler;
astore 2
start local 2 3: aload 2
ifnull 4
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endFuture:Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.isComplete:()Z
ifeq 7
4: StackMap locals: io.vertx.core.Handler io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
getstatic io.vertx.core.http.impl.HttpClientRequestImpl.log:Lio/vertx/core/impl/logging/Logger;
aload 1
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
5: aload 3
monitorexit
6: return
7: StackMap locals:
StackMap stack:
aload 3
monitorexit
8: goto 11
end local 2 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl java.lang.Throwable 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 java.lang.Throwable io.vertx.core.Handler
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
aload 1
aload 2
invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
12: 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
13: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 14 1 t Ljava/lang/Throwable;
3 9 2 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
11 14 2 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Exception table:
from to target type
2 6 9 any
7 8 9 any
9 10 9 any
MethodParameters:
Name Flags
t
public synchronized io.vertx.core.http.HttpClientRequest setFollowRedirects(boolean);
descriptor: (Z)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: iload 1
ifeq 4
2: 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
3: goto 5
4: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
5: StackMap locals:
StackMap stack:
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 followRedirects Z
MethodParameters:
Name Flags
followRedirects
public synchronized io.vertx.core.http.HttpClientRequest setMaxRedirects(int);
descriptor: (I)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: 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
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
4: aload 0
iload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
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 maxRedirects I
MethodParameters:
Name Flags
maxRedirects
public synchronized io.vertx.core.http.impl.HttpClientRequestImpl setChunked(boolean);
descriptor: (Z)Lio/vertx/core/http/impl/HttpClientRequestImpl;
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
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headWritten:Z
ifeq 3
2: 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
3: StackMap locals:
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 5
4: aload 0
iload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
5: StackMap locals:
StackMap stack:
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 chunked Z
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 io.vertx.core.MultiMap ();
descriptor: ()Lio/vertx/core/MultiMap;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, 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/HeadersMultiMap;
ifnonnull 2
1: aload 0
invokestatic io.vertx.core.http.impl.headers.HeadersMultiMap.httpHeaders:()Lio/vertx/core/http/impl/headers/HeadersMultiMap;
putfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/HeadersMultiMap;
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/HeadersMultiMap;
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 synchronized io.vertx.core.http.HttpClientRequest setWriteQueueMaxSize(int);
descriptor: (I)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
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
iload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.doSetWriteQueueMaxSize:(I)V
2: aload 0
areturn
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 maxSize I
MethodParameters:
Name Flags
maxSize
public boolean writeQueueFull();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
dup
astore 1
monitorenter
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: aload 1
monitorexit
3: goto 6
StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
4: aload 1
monitorexit
5: athrow
6: StackMap locals:
StackMap stack:
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
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
Exception table:
from to target type
1 3 4 any
4 5 4 any
public io.vertx.core.http.HttpVersion version();
descriptor: ()Lio/vertx/core/http/HttpVersion;
flags: (0x0001) ACC_PUBLIC
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;
invokeinterface io.vertx.core.http.impl.HttpClientStream.version:()Lio/vertx/core/http/HttpVersion;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
private synchronized io.vertx.core.Handler<java.lang.Throwable> exceptionHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.exceptionHandler: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<Ljava/lang/Throwable;>;
public synchronized io.vertx.core.http.HttpClientRequest exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
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 4
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.exceptionHandler:Lio/vertx/core/Handler;
3: goto 5
4: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.vertx.core.http.impl.HttpClientRequestImpl.exceptionHandler:Lio/vertx/core/Handler;
5: StackMap locals:
StackMap stack:
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 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.core.http.HttpClientRequest drainHandler(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
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
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 5 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 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.Future<java.lang.Void> sendHead();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.sendHead:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
pop
2: aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
1 3 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.core.http.HttpClientRequest sendHead(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, 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
aconst_null
iconst_0
iconst_0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.doWrite:(Lio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
2: aload 0
areturn
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 headersHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
headersHandler
public io.vertx.core.Future<io.vertx.core.http.HttpClientResponse> connect();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 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.isPipelining:()Z
ifeq 2
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
ldc "Cannot upgrade a pipe-lined request"
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
2: StackMap locals:
StackMap stack:
aload 0
aconst_null
iconst_0
iconst_1
invokedynamic handle()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/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.doWrite:(Lio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
3: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.response:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
Signature: ()Lio/vertx/core/Future<Lio/vertx/core/http/HttpClientResponse;>;
public void connect(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.HttpClientResponse>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.connect:()Lio/vertx/core/Future;
astore 2
start local 2 1: aload 1
ifnull 3
2: aload 2
aload 1
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 2 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/AsyncResult<Lio/vertx/core/http/HttpClientResponse;>;>;
1 4 2 fut Lio/vertx/core/Future<Lio/vertx/core/http/HttpClientResponse;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/HttpClientResponse;>;>;)V
MethodParameters:
Name Flags
handler
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
boolean reset(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x0000)
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.reset:Ljava/lang/Throwable;
ifnull 4
2: aload 2
monitorexit
3: iconst_0
ireturn
4: StackMap locals: 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 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
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.reset:(Ljava/lang/Throwable;)V
10: iconst_1
ireturn
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 cause Ljava/lang/Throwable;
Exception table:
from to target type
1 3 7 any
4 6 7 any
7 8 7 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 synchronized io.vertx.core.http.HttpConnection connection();
descriptor: ()Lio/vertx/core/http/HttpConnection;
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;
invokeinterface io.vertx.core.http.impl.HttpClientStream.connection:()Lio/vertx/core/http/impl/HttpClientConnection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
public 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: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
dup
astore 4
monitorenter
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkEnded:()V
2: aload 4
monitorexit
3: goto 6
StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl int int io.vertx.core.buffer.Buffer io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
6: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
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
7: aload 0
areturn
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 type I
0 8 2 flags I
0 8 3 payload Lio/vertx/core/buffer/Buffer;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
type
flags
payload
private void handleDrained(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x0002) ACC_PRIVATE
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.drainHandler:Lio/vertx/core/Handler;
astore 2
start local 2 2: aload 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 3
monitorexit
4: return
5: StackMap locals:
StackMap stack:
aload 3
monitorexit
6: goto 9
end local 2 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl java.lang.Void top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
7: aload 3
monitorexit
8: athrow
start local 2 9: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl java.lang.Void io.vertx.core.Handler
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
aload 2
invokeinterface io.vertx.core.impl.ContextInternal.dispatch:(Lio/vertx/core/Handler;)V
10: return
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 v Ljava/lang/Void;
2 7 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
9 11 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Exception table:
from to target type
1 4 7 any
5 6 7 any
7 8 7 any
MethodParameters:
Name Flags
v
private void handleNextRequest(io.vertx.core.http.HttpClientRequest, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.HttpClientResponse>>, );
descriptor: (Lio/vertx/core/http/HttpClientRequest;Lio/vertx/core/Handler;J)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 2
invokeinterface io.vertx.core.http.HttpClientRequest.response:(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
invokevirtual 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
4: 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
5: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/HeadersMultiMap;
ifnull 7
6: 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/HeadersMultiMap;
invokeinterface io.vertx.core.MultiMap.addAll:(Lio/vertx/core/MultiMap;)Lio/vertx/core/MultiMap;
pop
7: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.endFuture:Lio/vertx/core/Future;
lload 3
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$4(JLio/vertx/core/http/HttpClientRequest;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
8: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 9 1 next Lio/vertx/core/http/HttpClientRequest;
0 9 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/HttpClientResponse;>;>;
0 9 3 timeoutMs J
Signature: (Lio/vertx/core/http/HttpClientRequest;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/HttpClientResponse;>;>;J)V
MethodParameters:
Name Flags
next
handler
timeoutMs
private void handleContinue(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x0002) ACC_PRIVATE
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.continueHandler:Lio/vertx/core/Handler;
astore 2
start local 2 2: aload 3
monitorexit
3: goto 6
end local 2 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl java.lang.Void top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
4: aload 3
monitorexit
5: athrow
start local 2 6: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl java.lang.Void io.vertx.core.Handler
StackMap stack:
aload 2
ifnull 8
7: aload 2
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 9 1 v Ljava/lang/Void;
2 4 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
6 9 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
v
void handleResponse(io.vertx.core.Promise<io.vertx.core.http.HttpClientResponse>, io.vertx.core.http.HttpClientResponse, );
descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/http/HttpClientResponse;J)V
flags: (0x0000)
Code:
stack=5, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.reset:Ljava/lang/Throwable;
ifnull 2
1: return
2: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.http.HttpClientResponse.statusCode:()I
istore 5
start local 5 3: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.followRedirects:I
ifle 8
iload 5
sipush 300
if_icmplt 8
iload 5
sipush 400
if_icmpge 8
4: 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 2
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.Future
astore 6
start local 6 5: aload 6
ifnull 8
6: aload 6
aload 0
aload 1
lload 3
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestImpl;Lio/vertx/core/Promise;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$5(Lio/vertx/core/Promise;JLio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: return
end local 6 8: StackMap locals: int
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
9: return
end local 5 end local 3 end local 2 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 promise Lio/vertx/core/Promise<Lio/vertx/core/http/HttpClientResponse;>;
0 10 2 resp Lio/vertx/core/http/HttpClientResponse;
0 10 3 timeoutMs J
3 10 5 statusCode I
5 8 6 next Lio/vertx/core/Future<Lio/vertx/core/http/RequestOptions;>;
Signature: (Lio/vertx/core/Promise<Lio/vertx/core/http/HttpClientResponse;>;Lio/vertx/core/http/HttpClientResponse;J)V
MethodParameters:
Name Flags
promise
resp
timeoutMs
public io.vertx.core.Future<java.lang.Void> end(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Ljava/lang/String;Lio/vertx/core/Handler;)V
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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 chunk Ljava/lang/String;
1 3 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
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 io.vertx.core.Future<java.lang.Void> end(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 1: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
2: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
1 3 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
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 io.vertx.core.Future<java.lang.Void> end(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 1: 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
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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 chunk Lio/vertx/core/buffer/Buffer;
1 3 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future<Ljava/lang/Void;>;
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 io.vertx.core.Future<java.lang.Void> end();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.end:(Lio/vertx/core/Handler;)V
2: aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
1 3 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
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.Future<java.lang.Void> write(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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 chunk Lio/vertx/core/buffer/Buffer;
1 3 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
chunk
public void 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;)V
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: 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 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;>;>;)V
MethodParameters:
Name Flags
chunk
handler
public io.vertx.core.Future<java.lang.Void> write(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Ljava/lang/String;Lio/vertx/core/Handler;)V
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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 chunk Ljava/lang/String;
1 3 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
chunk
public void write(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=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: 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 io.vertx.core.Future<java.lang.Void> write(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 1: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.write:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
2: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
1 3 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
chunk
enc
public void 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;)V
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: 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
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/HeadersMultiMap;
ifnull 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/HeadersMultiMap;
getstatic io.vertx.core.http.HttpHeaders.CONTENT_LENGTH:Ljava/lang/CharSequence;
invokevirtual io.vertx.core.http.impl.headers.HeadersMultiMap.contains:(Ljava/lang/CharSequence;)Z
ifne 2
StackMap locals:
StackMap stack:
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.isConnect:Z
ifne 2
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=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 2
ifeq 4
1: aload 1
ifnull 6
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.requiresContentLength:()Z
ifeq 6
2: 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
3: goto 6
StackMap locals:
StackMap stack:
4: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.requiresContentLength:()Z
ifeq 6
5: 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
6: StackMap locals:
StackMap stack:
aload 0
aload 1
iload 2
iconst_0
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.doWrite:(Lio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
7: return
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 buff Lio/netty/buffer/ByteBuf;
0 8 2 end Z
0 8 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
buff
end
completionHandler
private void doWrite(io.netty.buffer.ByteBuf, boolean, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
dup
astore 6
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.ended:Z
ifeq 5
2: aload 4
new java.lang.IllegalStateException
dup
ldc "Request already complete"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: aload 6
monitorexit
4: return
5: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.netty.buffer.ByteBuf int int io.vertx.core.Handler top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.checkResponseHandler:()V
6: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headWritten:Z
ifne 11
7: aload 0
iconst_1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.headWritten:Z
8: aload 0
iload 3
putfield io.vertx.core.http.impl.HttpClientRequestImpl.isConnect:Z
9: iconst_1
istore 5
start local 5 10: goto 12
end local 5 11: StackMap locals:
StackMap stack:
iconst_0
istore 5
start local 5 12: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.netty.buffer.ByteBuf int int io.vertx.core.Handler int io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 0
iload 2
putfield io.vertx.core.http.impl.HttpClientRequestImpl.ended:Z
13: aload 6
monitorexit
14: goto 17
end local 5 StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.netty.buffer.ByteBuf int int io.vertx.core.Handler top io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack: java.lang.Throwable
15: aload 6
monitorexit
16: athrow
start local 5 17: StackMap locals: io.vertx.core.http.impl.HttpClientRequestImpl io.netty.buffer.ByteBuf int int io.vertx.core.Handler int
StackMap stack:
iload 5
ifeq 23
18: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.getMethod:()Lio/vertx/core/http/HttpMethod;
astore 6
start local 6 19: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.getURI:()Ljava/lang/String;
astore 7
start local 7 20: new io.vertx.core.http.impl.HttpRequestHead
dup
aload 6
aload 7
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headers:Lio/vertx/core/http/impl/headers/HeadersMultiMap;
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.authority:()Ljava/lang/String;
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.absoluteURI:()Ljava/lang/String;
invokespecial io.vertx.core.http.impl.HttpRequestHead.<init>:(Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Lio/vertx/core/MultiMap;Ljava/lang/String;Ljava/lang/String;)V
astore 8
start local 8 21: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
aload 8
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.chunked:Z
aload 1
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;
iload 3
aload 4
invokeinterface io.vertx.core.http.impl.HttpClientStream.writeHead:(Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZLio/vertx/core/http/StreamPriority;ZLio/vertx/core/Handler;)V
end local 8 end local 7 end local 6 22: goto 26
23: StackMap locals:
StackMap stack:
aload 1
ifnonnull 25
iload 2
ifne 25
24: new java.lang.IllegalArgumentException
dup
invokespecial java.lang.IllegalArgumentException.<init>:()V
athrow
25: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
aload 1
iload 2
aload 4
invokeinterface io.vertx.core.http.impl.HttpClientStream.writeBuffer:(Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
26: StackMap locals:
StackMap stack:
iload 2
ifeq 28
27: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.tryComplete:()V
28: StackMap locals:
StackMap stack:
return
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 29 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 29 1 buff Lio/netty/buffer/ByteBuf;
0 29 2 end Z
0 29 3 connect Z
0 29 4 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
10 11 5 writeHead Z
12 15 5 writeHead Z
17 29 5 writeHead Z
19 22 6 method Lio/vertx/core/http/HttpMethod;
20 22 7 uri Ljava/lang/String;
21 22 8 head Lio/vertx/core/http/impl/HttpRequestHead;
Exception table:
from to target type
1 4 15 any
5 14 15 any
15 16 15 any
Signature: (Lio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
buff
end
connect
completionHandler
private void checkEnded();
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.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=0, locals=1, args_size=1
start local 0 0: return
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 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=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.headWritten:Z
ifeq 3
1: 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
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestImpl.priority:Lio/vertx/core/http/StreamPriority;
4: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 5 1 priority Lio/vertx/core/http/StreamPriority;
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=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.stream:Lio/vertx/core/http/impl/HttpClientStream;
invokeinterface io.vertx.core.http.impl.HttpClientStream.priority:()Lio/vertx/core/http/StreamPriority;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
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 void write(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.write:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
return
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.Future write(java.lang.Object);
descriptor: (Ljava/lang/Object;)Lio/vertx/core/Future;
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/Future;
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.StreamBase exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/StreamBase;
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.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream exceptionHandler(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.exceptionHandler:(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 io.vertx.core.Future end(java.lang.Object);
descriptor: (Ljava/lang/Object;)Lio/vertx/core/Future;
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;)Lio/vertx/core/Future;
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 static void lambda$3(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private static void lambda$4(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:()Lio/vertx/core/Future;
pop
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$5(io.vertx.core.Promise, long, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Promise;JLio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=7, args_size=4
start local 0 start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.http.RequestOptions
astore 5
start local 5 2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestImpl.client:Lio/vertx/core/http/impl/HttpClientImpl;
aload 5
invokevirtual io.vertx.core.http.impl.HttpClientImpl.request:(Lio/vertx/core/http/RequestOptions;)Lio/vertx/core/Future;
astore 6
start local 6 3: aload 6
aload 0
aload 1
lload 2
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestImpl;Lio/vertx/core/Promise;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$6(Lio/vertx/core/Promise;JLio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
end local 6 end local 5 4: goto 6
5: StackMap locals:
StackMap stack:
aload 0
aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.fail:(Ljava/lang/Throwable;)V
6: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 7 4 ar1 Lio/vertx/core/AsyncResult<Lio/vertx/core/http/RequestOptions;>;
2 4 5 options Lio/vertx/core/http/RequestOptions;
3 4 6 f Lio/vertx/core/Future<Lio/vertx/core/http/HttpClientRequest;>;
private void lambda$6(io.vertx.core.Promise, long, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Promise;JLio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.http.HttpClientRequest
aload 1
lload 2
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleNextRequest:(Lio/vertx/core/http/HttpClientRequest;Lio/vertx/core/Handler;J)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/HttpClientRequestImpl;
0 5 4 ar2 Lio/vertx/core/AsyncResult<Lio/vertx/core/http/HttpClientRequest;>;
}
SourceFile: "HttpClientRequestImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles