final class jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher$TubePublisherWrapper extends jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher$TubePublisherWrapper
super_class: jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher
{
final java.util.concurrent.Flow$Publisher<java.util.List<java.nio.ByteBuffer>> delegate;
descriptor: Ljava/util/concurrent/Flow$Publisher;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/Flow$Publisher<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
public void <init>(java.util.concurrent.Flow$Publisher<java.util.List<java.nio.ByteBuffer>>);
descriptor: (Ljava/util/concurrent/Flow$Publisher;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher.<init>:()V
1: aload 0
aload 1
putfield jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher$TubePublisherWrapper.delegate:Ljava/util/concurrent/Flow$Publisher;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/internal/common/FlowTube$AbstractTubePublisher$TubePublisherWrapper;
0 3 1 delegate Ljava/util/concurrent/Flow$Publisher<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
Signature: (Ljava/util/concurrent/Flow$Publisher<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;)V
MethodParameters:
Name Flags
delegate
public void subscribe(java.util.concurrent.Flow$Subscriber<? super java.util.List<java.nio.ByteBuffer>>);
descriptor: (Ljava/util/concurrent/Flow$Subscriber;)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.internal.common.FlowTube$AbstractTubePublisher$TubePublisherWrapper.delegate:Ljava/util/concurrent/Flow$Publisher;
aload 1
invokeinterface java.util.concurrent.Flow$Publisher.subscribe:(Ljava/util/concurrent/Flow$Subscriber;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/internal/common/FlowTube$AbstractTubePublisher$TubePublisherWrapper;
0 2 1 subscriber Ljava/util/concurrent/Flow$Subscriber<-Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
Signature: (Ljava/util/concurrent/Flow$Subscriber<-Ljava/util/List<Ljava/nio/ByteBuffer;>;>;)V
MethodParameters:
Name Flags
subscriber
}
SourceFile: "FlowTube.java"
NestHost: jdk.incubator.http.internal.common.FlowTube
InnerClasses:
public abstract Publisher = java.util.concurrent.Flow$Publisher of java.util.concurrent.Flow
public abstract Subscriber = java.util.concurrent.Flow$Subscriber of java.util.concurrent.Flow
public abstract AbstractTubePublisher = jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher of jdk.incubator.http.internal.common.FlowTube
final TubePublisherWrapper = jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher$TubePublisherWrapper of jdk.incubator.http.internal.common.FlowTube$AbstractTubePublisher