public abstract class io.vertx.core.http.impl.HttpClientRequestBase implements io.vertx.core.http.HttpClientRequest
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.vertx.core.http.impl.HttpClientRequestBase
super_class: java.lang.Object
{
protected final io.vertx.core.http.impl.HttpClientImpl client;
descriptor: Lio/vertx/core/http/impl/HttpClientImpl;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected final io.vertx.core.impl.ContextInternal context;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected final io.vertx.core.http.impl.HttpClientStream stream;
descriptor: Lio/vertx/core/http/impl/HttpClientStream;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected final io.vertx.core.net.SocketAddress server;
descriptor: Lio/vertx/core/net/SocketAddress;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected final boolean ssl;
descriptor: Z
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
private io.vertx.core.http.HttpMethod method;
descriptor: Lio/vertx/core/http/HttpMethod;
flags: (0x0002) ACC_PRIVATE
private java.lang.String host;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private int port;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private java.lang.String uri;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String path;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String query;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private final io.vertx.core.impl.future.PromiseInternal<io.vertx.core.http.HttpClientResponse> responsePromise;
descriptor: Lio/vertx/core/impl/future/PromiseInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/impl/future/PromiseInternal<Lio/vertx/core/http/HttpClientResponse;>;
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 long currentTimeoutTimerId;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long currentTimeoutMs;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long lastDataReceived;
descriptor: J
flags: (0x0002) ACC_PRIVATE
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=3, 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
invokespecial java.lang.Object.<init>:()V
1: aload 0
ldc -1
putfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutTimerId:J
2: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestBase.client:Lio/vertx/core/http/impl/HttpClientImpl;
3: aload 0
aload 2
putfield io.vertx.core.http.impl.HttpClientRequestBase.stream:Lio/vertx/core/http/impl/HttpClientStream;
4: aload 0
aload 3
putfield io.vertx.core.http.impl.HttpClientRequestBase.responsePromise:Lio/vertx/core/impl/future/PromiseInternal;
5: aload 0
aload 3
invokeinterface io.vertx.core.impl.future.PromiseInternal.context:()Lio/vertx/core/impl/ContextInternal;
putfield io.vertx.core.http.impl.HttpClientRequestBase.context:Lio/vertx/core/impl/ContextInternal;
6: aload 0
aload 9
putfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
7: aload 0
aload 5
putfield io.vertx.core.http.impl.HttpClientRequestBase.method:Lio/vertx/core/http/HttpMethod;
8: aload 0
aload 6
putfield io.vertx.core.http.impl.HttpClientRequestBase.server:Lio/vertx/core/net/SocketAddress;
9: aload 0
aload 7
putfield io.vertx.core.http.impl.HttpClientRequestBase.host:Ljava/lang/String;
10: aload 0
iload 8
putfield io.vertx.core.http.impl.HttpClientRequestBase.port:I
11: aload 0
iload 4
putfield io.vertx.core.http.impl.HttpClientRequestBase.ssl:Z
12: aload 2
aload 0
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestBase;)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/HttpClientRequestBase.handlePush(Lio/vertx/core/http/impl/HttpClientPush;)V (5)
(Lio/vertx/core/http/impl/HttpClientPush;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.pushHandler:(Lio/vertx/core/Handler;)V
13: aload 2
aload 0
aload 2
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestBase;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/HttpClientRequestBase.lambda$1(Lio/vertx/core/http/impl/HttpClientStream;Lio/vertx/core/http/impl/HttpResponseHead;)V (7)
(Lio/vertx/core/http/impl/HttpResponseHead;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.headHandler:(Lio/vertx/core/Handler;)V
14: 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 15 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 15 1 client Lio/vertx/core/http/impl/HttpClientImpl;
0 15 2 stream Lio/vertx/core/http/impl/HttpClientStream;
0 15 3 responsePromise Lio/vertx/core/impl/future/PromiseInternal<Lio/vertx/core/http/HttpClientResponse;>;
0 15 4 ssl Z
0 15 5 method Lio/vertx/core/http/HttpMethod;
0 15 6 server Lio/vertx/core/net/SocketAddress;
0 15 7 host Ljava/lang/String;
0 15 8 port I
0 15 9 uri 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
uri
protected java.lang.String authority();
descriptor: ()Ljava/lang/String;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.port:I
bipush 80
if_icmpne 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.ssl:Z
ifeq 2
StackMap locals:
StackMap stack:
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.port:I
sipush 443
if_icmpne 3
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.ssl:Z
ifeq 3
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.host:Ljava/lang/String;
areturn
3: StackMap locals:
StackMap stack:
new java.lang.StringBuilder
dup
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.host:Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
bipush 58
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.port:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public int streamId();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.stream:Lio/vertx/core/http/impl/HttpClientStream;
invokeinterface io.vertx.core.http.impl.HttpClientStream.id:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public java.lang.String absoluteURI();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.ssl:Z
ifeq 1
ldc "https://"
goto 2
StackMap locals: io.vertx.core.http.impl.HttpClientRequestBase
StackMap stack: new 0 new 0
1: ldc "http://"
StackMap locals: io.vertx.core.http.impl.HttpClientRequestBase
StackMap stack: new 0 new 0 java.lang.String
2: invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.authority:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public java.lang.String query();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.query:Ljava/lang/String;
ifnonnull 2
1: aload 0
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
invokestatic io.vertx.core.http.impl.HttpUtils.parseQuery:(Ljava/lang/String;)Ljava/lang/String;
putfield io.vertx.core.http.impl.HttpClientRequestBase.query:Ljava/lang/String;
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.query:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public java.lang.String path();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.path:Ljava/lang/String;
ifnonnull 4
1: aload 0
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
invokevirtual java.lang.String.length:()I
ifle 2
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
invokestatic io.vertx.core.http.impl.HttpUtils.parsePath:(Ljava/lang/String;)Ljava/lang/String;
goto 3
StackMap locals:
StackMap stack: io.vertx.core.http.impl.HttpClientRequestBase
2: ldc ""
StackMap locals: io.vertx.core.http.impl.HttpClientRequestBase
StackMap stack: io.vertx.core.http.impl.HttpClientRequestBase java.lang.String
3: putfield io.vertx.core.http.impl.HttpClientRequestBase.path:Ljava/lang/String;
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.path:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public synchronized java.lang.String getURI();
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.HttpClientRequestBase.uri:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public synchronized io.vertx.core.http.HttpClientRequest setURI(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 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
2: aload 0
aconst_null
putfield io.vertx.core.http.impl.HttpClientRequestBase.path:Ljava/lang/String;
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/HttpClientRequestBase;
0 4 1 uri Ljava/lang/String;
MethodParameters:
Name Flags
uri
public java.lang.String getHost();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.host:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
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
getfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestBase.host:Ljava/lang/String;
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/HttpClientRequestBase;
0 3 1 host Ljava/lang/String;
MethodParameters:
Name Flags
host
public int getPort();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.port:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public synchronized io.vertx.core.http.HttpClientRequest setPort(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
iload 1
putfield io.vertx.core.http.impl.HttpClientRequestBase.port:I
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/HttpClientRequestBase;
0 2 1 port I
MethodParameters:
Name Flags
port
public synchronized io.vertx.core.http.HttpMethod getMethod();
descriptor: ()Lio/vertx/core/http/HttpMethod;
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.HttpClientRequestBase.method:Lio/vertx/core/http/HttpMethod;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public synchronized io.vertx.core.http.HttpClientRequest setMethod(io.vertx.core.http.HttpMethod);
descriptor: (Lio/vertx/core/http/HttpMethod;)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.HttpClientRequestBase.uri:Ljava/lang/String;
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
aload 1
putfield io.vertx.core.http.impl.HttpClientRequestBase.method:Lio/vertx/core/http/HttpMethod;
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/HttpClientRequestBase;
0 3 1 method Lio/vertx/core/http/HttpMethod;
MethodParameters:
Name Flags
method
public synchronized io.vertx.core.http.HttpClientRequest setTimeout(long);
descriptor: (J)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=7, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.cancelTimeout:()J
pop2
1: aload 0
lload 1
putfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutMs:J
2: aload 0
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.context:Lio/vertx/core/impl/ContextInternal;
lload 1
aload 0
lload 1
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientRequestBase;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/HttpClientRequestBase.lambda$6(JLjava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.impl.ContextInternal.setTimer:(JLio/vertx/core/Handler;)J
putfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutTimerId:J
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/HttpClientRequestBase;
0 4 1 timeoutMs J
MethodParameters:
Name Flags
timeoutMs
void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.fail:(Ljava/lang/Throwable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 2 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
void fail(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.cancelTimeout:()J
pop2
1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.responsePromise:Lio/vertx/core/impl/future/PromiseInternal;
aload 1
invokeinterface io.vertx.core.impl.future.PromiseInternal.tryFail:(Ljava/lang/Throwable;)Z
pop
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.responsePromise:Lio/vertx/core/impl/future/PromiseInternal;
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.result:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.HttpClientResponseImpl
astore 2
start local 2 3: aload 2
ifnull 5
4: aload 2
aload 1
invokevirtual io.vertx.core.http.impl.HttpClientResponseImpl.handleException:(Ljava/lang/Throwable;)V
5: StackMap locals: io.vertx.core.http.impl.HttpClientResponseImpl
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 6 1 t Ljava/lang/Throwable;
3 6 2 response Lio/vertx/core/http/impl/HttpClientResponseImpl;
MethodParameters:
Name Flags
t
void handlePush(io.vertx.core.http.impl.HttpClientPush);
descriptor: (Lio/vertx/core/http/impl/HttpClientPush;)V
flags: (0x0000)
Code:
stack=10, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.core.http.impl.HttpClientRequestPushPromise
dup
aload 1
getfield io.vertx.core.http.impl.HttpClientPush.stream:Lio/vertx/core/http/impl/HttpClientStream;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.client:Lio/vertx/core/http/impl/HttpClientImpl;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.ssl:Z
aload 1
getfield io.vertx.core.http.impl.HttpClientPush.method:Lio/vertx/core/http/HttpMethod;
aload 1
getfield io.vertx.core.http.impl.HttpClientPush.uri:Ljava/lang/String;
aload 1
getfield io.vertx.core.http.impl.HttpClientPush.host:Ljava/lang/String;
aload 1
getfield io.vertx.core.http.impl.HttpClientPush.port:I
aload 1
getfield io.vertx.core.http.impl.HttpClientPush.headers:Lio/vertx/core/MultiMap;
invokespecial io.vertx.core.http.impl.HttpClientRequestPushPromise.<init>:(Lio/vertx/core/http/impl/HttpClientStream;Lio/vertx/core/http/impl/HttpClientImpl;ZLio/vertx/core/http/HttpMethod;Ljava/lang/String;Ljava/lang/String;ILio/vertx/core/MultiMap;)V
astore 2
start local 2 1: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.pushHandler:Lio/vertx/core/Handler;
ifnull 4
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.pushHandler:Lio/vertx/core/Handler;
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: goto 5
4: StackMap locals: io.vertx.core.http.impl.HttpClientRequestPushPromise
StackMap stack:
aload 2
getstatic io.netty.handler.codec.http2.Http2Error.CANCEL:Lio/netty/handler/codec/http2/Http2Error;
invokevirtual io.netty.handler.codec.http2.Http2Error.code:()J
invokevirtual io.vertx.core.http.impl.HttpClientRequestPushPromise.reset:(J)Z
pop
5: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 6 1 push Lio/vertx/core/http/impl/HttpClientPush;
1 6 2 pushReq Lio/vertx/core/http/impl/HttpClientRequestPushPromise;
MethodParameters:
Name Flags
push
void handleResponse(io.vertx.core.http.HttpClientResponse);
descriptor: (Lio/vertx/core/http/HttpClientResponse;)V
flags: (0x0000)
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.responsePromise:Lio/vertx/core/impl/future/PromiseInternal;
aload 1
aload 0
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.cancelTimeout:()J
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.handleResponse:(Lio/vertx/core/Promise;Lio/vertx/core/http/HttpClientResponse;J)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 2 1 resp Lio/vertx/core/http/HttpClientResponse;
MethodParameters:
Name Flags
resp
abstract 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: (0x0400) ACC_ABSTRACT
Signature: (Lio/vertx/core/Promise<Lio/vertx/core/http/HttpClientResponse;>;Lio/vertx/core/http/HttpClientResponse;J)V
MethodParameters:
Name Flags
promise
resp
timeoutMs
private synchronized long cancelTimeout();
descriptor: ()J
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutTimerId:J
dup2
lstore 1
start local 1 1: ldc -1
lcmp
ifeq 6
2: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getVertx:()Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutTimerId:J
invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
pop
3: aload 0
ldc -1
putfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutTimerId:J
4: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutMs:J
lstore 1
5: aload 0
lconst_0
putfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutMs:J
6: StackMap locals: long
StackMap stack:
lload 1
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
1 7 1 ret J
private void handleTimeout(long);
descriptor: (J)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=8, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
ldc -1
putfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutTimerId:J
2: aload 0
lconst_0
putfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutMs:J
3: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.lastDataReceived:J
lconst_0
lcmp
ifle 11
4: invokestatic java.lang.System.currentTimeMillis:()J
lstore 4
start local 4 5: lload 4
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.lastDataReceived:J
lsub
lstore 6
start local 6 6: lload 6
lload 1
lcmp
ifge 11
7: aload 0
lconst_0
putfield io.vertx.core.http.impl.HttpClientRequestBase.lastDataReceived:J
8: aload 0
lload 1
lload 6
lsub
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.setTimeout:(J)Lio/vertx/core/http/HttpClientRequest;
pop
9: aload 3
monitorexit
10: return
end local 6 end local 4 11: StackMap locals: io.vertx.core.http.impl.HttpClientRequestBase
StackMap stack:
aload 3
monitorexit
12: goto 15
StackMap locals:
StackMap stack: java.lang.Throwable
13: aload 3
monitorexit
14: athrow
15: StackMap locals:
StackMap stack:
aload 0
lload 1
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.method:Lio/vertx/core/http/HttpMethod;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.server:Lio/vertx/core/net/SocketAddress;
aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.uri:Ljava/lang/String;
invokestatic io.vertx.core.http.impl.HttpClientRequestBase.timeoutEx:(JLio/vertx/core/http/HttpMethod;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;)Lio/vertx/core/http/impl/NoStackTraceTimeoutException;
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.reset:(Ljava/lang/Throwable;)Z
pop
16: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 17 1 timeoutMs J
5 11 4 now J
6 11 6 timeSinceLastData J
Exception table:
from to target type
1 10 13 any
11 12 13 any
13 14 13 any
MethodParameters:
Name Flags
timeoutMs
static io.vertx.core.http.impl.NoStackTraceTimeoutException timeoutEx(long, io.vertx.core.http.HttpMethod, io.vertx.core.net.SocketAddress, java.lang.String);
descriptor: (JLio/vertx/core/http/HttpMethod;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;)Lio/vertx/core/http/impl/NoStackTraceTimeoutException;
flags: (0x0008) ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 2 start local 3 start local 4 0: new io.vertx.core.http.impl.NoStackTraceTimeoutException
dup
new java.lang.StringBuilder
dup
ldc "The timeout period of "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
lload 0
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc "ms has been exceeded while executing "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " for server "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial io.vertx.core.http.impl.NoStackTraceTimeoutException.<init>:(Ljava/lang/String;)V
areturn
end local 4 end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 timeoutMs J
0 1 2 method Lio/vertx/core/http/HttpMethod;
0 1 3 server Lio/vertx/core/net/SocketAddress;
0 1 4 uri Ljava/lang/String;
MethodParameters:
Name Flags
timeoutMs
method
server
uri
synchronized void dataReceived();
descriptor: ()V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.currentTimeoutTimerId:J
ldc -1
lcmp
ifeq 2
1: aload 0
invokestatic java.lang.System.currentTimeMillis:()J
putfield io.vertx.core.http.impl.HttpClientRequestBase.lastDataReceived:J
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
public boolean reset(long);
descriptor: (J)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
new io.vertx.core.http.StreamResetException
dup
lload 1
invokespecial io.vertx.core.http.StreamResetException.<init>:(J)V
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.reset:(Ljava/lang/Throwable;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 1 1 code J
MethodParameters:
Name Flags
code
public boolean reset(long, java.lang.Throwable);
descriptor: (JLjava/lang/Throwable;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
new io.vertx.core.http.StreamResetException
dup
lload 1
aload 3
invokespecial io.vertx.core.http.StreamResetException.<init>:(JLjava/lang/Throwable;)V
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.reset:(Ljava/lang/Throwable;)Z
ireturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 1 1 code J
0 1 3 cause Ljava/lang/Throwable;
MethodParameters:
Name Flags
code
cause
abstract boolean reset(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x0400) ACC_ABSTRACT
MethodParameters:
Name Flags
cause
public io.vertx.core.http.HttpClientRequest response(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.HttpClientResponse>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpClientRequest;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.responsePromise:Lio/vertx/core/impl/future/PromiseInternal;
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
aload 1
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
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/HttpClientRequestBase;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/HttpClientResponse;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/HttpClientResponse;>;>;)Lio/vertx/core/http/HttpClientRequest;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<io.vertx.core.http.HttpClientResponse> response();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.HttpClientRequestBase.responsePromise:Lio/vertx/core/impl/future/PromiseInternal;
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
Signature: ()Lio/vertx/core/Future<Lio/vertx/core/http/HttpClientResponse;>;
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.HttpClientRequestBase.pushHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
Signature: ()Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientRequest;>;
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.HttpClientRequestBase.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/HttpClientRequestBase;
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
private void lambda$1(io.vertx.core.http.impl.HttpClientStream, io.vertx.core.http.impl.HttpResponseHead);
descriptor: (Lio/vertx/core/http/impl/HttpClientStream;Lio/vertx/core/http/impl/HttpResponseHead;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=8, locals=4, args_size=3
start local 0 start local 2 0: new io.vertx.core.http.impl.HttpClientResponseImpl
dup
aload 0
aload 1
invokeinterface io.vertx.core.http.impl.HttpClientStream.version:()Lio/vertx/core/http/HttpVersion;
aload 1
aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.statusCode:I
aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.statusMessage:Ljava/lang/String;
aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.headers:Lio/vertx/core/MultiMap;
invokespecial io.vertx.core.http.impl.HttpClientResponseImpl.<init>:(Lio/vertx/core/http/impl/HttpClientRequestBase;Lio/vertx/core/http/HttpVersion;Lio/vertx/core/http/impl/HttpClientStream;ILjava/lang/String;Lio/vertx/core/MultiMap;)V
astore 3
start local 3 1: aload 1
aload 3
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientResponseImpl;)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/HttpClientResponseImpl.handleChunk(Lio/vertx/core/buffer/Buffer;)V (5)
(Lio/vertx/core/buffer/Buffer;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.chunkHandler:(Lio/vertx/core/Handler;)V
2: aload 1
aload 3
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientResponseImpl;)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/HttpClientResponseImpl.handleEnd(Lio/vertx/core/MultiMap;)V (5)
(Lio/vertx/core/MultiMap;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.endHandler:(Lio/vertx/core/Handler;)V
3: aload 1
aload 3
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientResponseImpl;)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/HttpClientResponseImpl.handlePriorityChange(Lio/vertx/core/http/StreamPriority;)V (5)
(Lio/vertx/core/http/StreamPriority;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.priorityHandler:(Lio/vertx/core/Handler;)V
4: aload 1
aload 3
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/HttpClientResponseImpl;)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/HttpClientResponseImpl.handleUnknownFrame(Lio/vertx/core/http/HttpFrame;)V (5)
(Lio/vertx/core/http/HttpFrame;)V
invokeinterface io.vertx.core.http.impl.HttpClientStream.unknownFrameHandler:(Lio/vertx/core/Handler;)V
5: aload 0
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.handleResponse:(Lio/vertx/core/http/HttpClientResponse;)V
end local 3 6: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 7 2 resp Lio/vertx/core/http/impl/HttpResponseHead;
1 6 3 response Lio/vertx/core/http/impl/HttpClientResponseImpl;
private void lambda$6(long, java.lang.Long);
descriptor: (JLjava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 3 0: aload 0
lload 1
invokevirtual io.vertx.core.http.impl.HttpClientRequestBase.handleTimeout:(J)V
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/HttpClientRequestBase;
0 1 3 id Ljava/lang/Long;
}
SourceFile: "HttpClientRequestBase.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles