class jdk.incubator.http.ResponseProcessors$NullProcessor<T> extends jdk.incubator.http.ResponseProcessors$AbstractProcessor<T>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: jdk.incubator.http.ResponseProcessors$NullProcessor
super_class: jdk.incubator.http.ResponseProcessors$AbstractProcessor
{
java.util.concurrent.Flow$Subscription subscription;
descriptor: Ljava/util/concurrent/Flow$Subscription;
flags: (0x0000)
final java.util.concurrent.CompletableFuture<T> cf;
descriptor: Ljava/util/concurrent/CompletableFuture;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/CompletableFuture<TT;>;
final java.util.Optional<T> result;
descriptor: Ljava/util/Optional;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/Optional<TT;>;
void <init>(java.util.Optional<T>);
descriptor: (Ljava/util/Optional;)V
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial jdk.incubator.http.ResponseProcessors$AbstractProcessor.<init>:()V
1: aload 0
new jdk.incubator.http.internal.common.MinimalFuture
dup
invokespecial jdk.incubator.http.internal.common.MinimalFuture.<init>:()V
putfield jdk.incubator.http.ResponseProcessors$NullProcessor.cf:Ljava/util/concurrent/CompletableFuture;
2: aload 0
aload 1
putfield jdk.incubator.http.ResponseProcessors$NullProcessor.result:Ljava/util/Optional;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Ljdk/incubator/http/ResponseProcessors$NullProcessor<TT;>;
0 4 1 result Ljava/util/Optional<TT;>;
Signature: (Ljava/util/Optional<TT;>;)V
MethodParameters:
Name Flags
result
public void onSubscribe(java.util.concurrent.Flow$Subscription);
descriptor: (Ljava/util/concurrent/Flow$Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield jdk.incubator.http.ResponseProcessors$NullProcessor.subscription:Ljava/util/concurrent/Flow$Subscription;
1: aload 1
ldc 9223372036854775807
invokeinterface java.util.concurrent.Flow$Subscription.request:(J)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/ResponseProcessors$NullProcessor<TT;>;
0 3 1 subscription Ljava/util/concurrent/Flow$Subscription;
MethodParameters:
Name Flags
subscription
public void onNext(java.nio.ByteBuffer);
descriptor: (Ljava/nio/ByteBuffer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 1
invokevirtual java.nio.ByteBuffer.limit:()I
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/ByteBuffer;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/ResponseProcessors$NullProcessor<TT;>;
0 2 1 item Ljava/nio/ByteBuffer;
MethodParameters:
Name Flags
item
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.incubator.http.ResponseProcessors$NullProcessor.cf:Ljava/util/concurrent/CompletableFuture;
aload 1
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/ResponseProcessors$NullProcessor<TT;>;
0 2 1 throwable Ljava/lang/Throwable;
MethodParameters:
Name Flags
throwable
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.ResponseProcessors$NullProcessor.result:Ljava/util/Optional;
invokevirtual java.util.Optional.isPresent:()Z
ifeq 3
1: aload 0
getfield jdk.incubator.http.ResponseProcessors$NullProcessor.cf:Ljava/util/concurrent/CompletableFuture;
aload 0
getfield jdk.incubator.http.ResponseProcessors$NullProcessor.result:Ljava/util/Optional;
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
pop
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.ResponseProcessors$NullProcessor.cf:Ljava/util/concurrent/CompletableFuture;
aconst_null
invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
pop
4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Ljdk/incubator/http/ResponseProcessors$NullProcessor<TT;>;
public java.util.concurrent.CompletionStage<T> getBody();
descriptor: ()Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.ResponseProcessors$NullProcessor.cf:Ljava/util/concurrent/CompletableFuture;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljdk/incubator/http/ResponseProcessors$NullProcessor<TT;>;
Signature: ()Ljava/util/concurrent/CompletionStage<TT;>;
public void onNext(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast java.nio.ByteBuffer
invokevirtual jdk.incubator.http.ResponseProcessors$NullProcessor.onNext:(Ljava/nio/ByteBuffer;)V
return
LocalVariableTable:
Start End Slot Name Signature
}
Signature: <T:Ljava/lang/Object;>Ljdk/incubator/http/ResponseProcessors$AbstractProcessor<TT;>;
SourceFile: "ResponseProcessors.java"
NestHost: jdk.incubator.http.ResponseProcessors
InnerClasses:
public abstract Subscription = java.util.concurrent.Flow$Subscription of java.util.concurrent.Flow
abstract AbstractProcessor = jdk.incubator.http.ResponseProcessors$AbstractProcessor of jdk.incubator.http.ResponseProcessors
NullProcessor = jdk.incubator.http.ResponseProcessors$NullProcessor of jdk.incubator.http.ResponseProcessors