class jdk.incubator.http.RequestProcessors$IterableProcessor extends jdk.incubator.http.RequestProcessors$ProcessorBase implements jdk.incubator.http.HttpRequest$BodyProcessor
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: jdk.incubator.http.RequestProcessors$IterableProcessor
super_class: jdk.incubator.http.RequestProcessors$ProcessorBase
{
private volatile java.util.concurrent.Flow$Publisher<java.nio.ByteBuffer> delegate;
descriptor: Ljava/util/concurrent/Flow$Publisher;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
Signature: Ljava/util/concurrent/Flow$Publisher<Ljava/nio/ByteBuffer;>;
private final java.lang.Iterable<byte[]> content;
descriptor: Ljava/lang/Iterable;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/lang/Iterable<[B>;
private volatile long contentLength;
descriptor: J
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
void <init>(java.lang.Iterable<byte[]>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial jdk.incubator.http.RequestProcessors$ProcessorBase.<init>:()V
1: aload 0
aload 1
putfield jdk.incubator.http.RequestProcessors$IterableProcessor.content:Ljava/lang/Iterable;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/RequestProcessors$IterableProcessor;
0 3 1 content Ljava/lang/Iterable<[B>;
Signature: (Ljava/lang/Iterable<[B>;)V
MethodParameters:
Name Flags
content
public java.util.Iterator<java.nio.ByteBuffer> iterator();
descriptor: ()Ljava/util/Iterator;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new jdk.incubator.http.RequestProcessors$IterableProcessor$ByteBufferIterator
dup
aload 0
invokespecial jdk.incubator.http.RequestProcessors$IterableProcessor$ByteBufferIterator.<init>:(Ljdk/incubator/http/RequestProcessors$IterableProcessor;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljdk/incubator/http/RequestProcessors$IterableProcessor;
Signature: ()Ljava/util/Iterator<Ljava/nio/ByteBuffer;>;
public void subscribe(java.util.concurrent.Flow$Subscriber<? super java.nio.ByteBuffer>);
descriptor: (Ljava/util/concurrent/Flow$Subscriber;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokedynamic iterator(Ljdk/incubator/http/RequestProcessors$IterableProcessor;)Ljava/lang/Iterable;
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/util/Iterator;
jdk/incubator/http/RequestProcessors$IterableProcessor.iterator()Ljava/util/Iterator; (5)
()Ljava/util/Iterator;
astore 2
start local 2 1: aload 0
new jdk.incubator.http.PullPublisher
dup
aload 2
invokespecial jdk.incubator.http.PullPublisher.<init>:(Ljava/lang/Iterable;)V
putfield jdk.incubator.http.RequestProcessors$IterableProcessor.delegate:Ljava/util/concurrent/Flow$Publisher;
2: aload 0
getfield jdk.incubator.http.RequestProcessors$IterableProcessor.delegate:Ljava/util/concurrent/Flow$Publisher;
aload 1
invokeinterface java.util.concurrent.Flow$Publisher.subscribe:(Ljava/util/concurrent/Flow$Subscriber;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Ljdk/incubator/http/RequestProcessors$IterableProcessor;
0 4 1 subscriber Ljava/util/concurrent/Flow$Subscriber<-Ljava/nio/ByteBuffer;>;
1 4 2 iterable Ljava/lang/Iterable<Ljava/nio/ByteBuffer;>;
Signature: (Ljava/util/concurrent/Flow$Subscriber<-Ljava/nio/ByteBuffer;>;)V
MethodParameters:
Name Flags
subscriber
static long computeLength(java.lang.Iterable<byte[]>);
descriptor: (Ljava/lang/Iterable;)J
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=5, args_size=1
start local 0 0: lconst_0
lstore 1
start local 1 1: aload 0
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: java.lang.Iterable long top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast byte[]
astore 3
start local 3 3: lload 1
aload 3
arraylength
i2l
invokestatic java.lang.Math.addExact:(JJ)J
lstore 1
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: lload 1
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 bytes Ljava/lang/Iterable<[B>;
1 6 1 len J
3 4 3 b [B
Signature: (Ljava/lang/Iterable<[B>;)J
MethodParameters:
Name Flags
bytes
public long contentLength();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.RequestProcessors$IterableProcessor.contentLength:J
lconst_0
lcmp
ifne 8
1: aload 0
dup
astore 1
monitorenter
2: aload 0
getfield jdk.incubator.http.RequestProcessors$IterableProcessor.contentLength:J
lconst_0
lcmp
ifne 4
3: aload 0
aload 0
getfield jdk.incubator.http.RequestProcessors$IterableProcessor.content:Ljava/lang/Iterable;
invokestatic jdk.incubator.http.RequestProcessors$IterableProcessor.computeLength:(Ljava/lang/Iterable;)J
putfield jdk.incubator.http.RequestProcessors$IterableProcessor.contentLength:J
4: StackMap locals: jdk.incubator.http.RequestProcessors$IterableProcessor
StackMap stack:
aload 1
monitorexit
5: goto 8
StackMap locals:
StackMap stack: java.lang.Throwable
6: aload 1
monitorexit
7: athrow
8: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.RequestProcessors$IterableProcessor.contentLength:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Ljdk/incubator/http/RequestProcessors$IterableProcessor;
Exception table:
from to target type
2 5 6 any
6 7 6 any
}
SourceFile: "RequestProcessors.java"
NestHost: jdk.incubator.http.RequestProcessors
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
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 BodyProcessor = jdk.incubator.http.HttpRequest$BodyProcessor of jdk.incubator.http.HttpRequest
IterableProcessor = jdk.incubator.http.RequestProcessors$IterableProcessor of jdk.incubator.http.RequestProcessors
ByteBufferIterator = jdk.incubator.http.RequestProcessors$IterableProcessor$ByteBufferIterator of jdk.incubator.http.RequestProcessors$IterableProcessor
abstract ProcessorBase = jdk.incubator.http.RequestProcessors$ProcessorBase of jdk.incubator.http.RequestProcessors