final class jdk.internal.net.http.PullPublisher$Subscription$PullTask extends jdk.internal.net.http.common.SequentialScheduler$CompleteRestartableTask
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: jdk.internal.net.http.PullPublisher$Subscription$PullTask
super_class: jdk.internal.net.http.common.SequentialScheduler$CompleteRestartableTask
{
final jdk.internal.net.http.PullPublisher$Subscription this$1;
descriptor: Ljdk/internal/net/http/PullPublisher$Subscription;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(jdk.internal.net.http.PullPublisher$Subscription);
descriptor: (Ljdk/internal/net/http/PullPublisher$Subscription;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 // jdk.internal.net.http.PullPublisher$Subscription$PullTask this
0: .line 90
aload 0 /* this */
aload 1
putfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
aload 0 /* this */
invokespecial jdk.internal.net.http.common.SequentialScheduler$CompleteRestartableTask.<init>:()V
return
end local 0 // jdk.internal.net.http.PullPublisher$Subscription$PullTask this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljdk/internal/net/http/PullPublisher$Subscription$PullTask;
MethodParameters:
Name Flags
this$0 final
protected void run();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=4, args_size=1
start local 0 // jdk.internal.net.http.PullPublisher$Subscription$PullTask this
0: .line 93
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.completed:Z
ifne 1
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.cancelled:Z
ifeq 2
1: .line 94
StackMap locals:
StackMap stack:
return
2: .line 97
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.error:Ljava/lang/Throwable;
astore 1 /* t */
start local 1 // java.lang.Throwable t
3: .line 98
aload 1 /* t */
ifnull 18
4: .line 99
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
iconst_1
putfield jdk.internal.net.http.PullPublisher$Subscription.completed:Z
5: .line 100
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.pullScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
invokevirtual jdk.internal.net.http.common.SequentialScheduler.stop:()V
6: .line 101
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.subscriber:Ljava/util/concurrent/Flow$Subscriber;
aload 1 /* t */
invokeinterface java.util.concurrent.Flow$Subscriber.onError:(Ljava/lang/Throwable;)V
7: .line 102
return
8: .line 108
StackMap locals: java.lang.Throwable
StackMap stack:
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.iter:Ljava/util/Iterator;
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
9: .line 109
goto 19
10: .line 111
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.iter:Ljava/util/Iterator;
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
astore 2 /* next */
start local 2 // java.lang.Object next
11: .line 112
goto 17
end local 2 // java.lang.Object next
StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 3 /* t1 */
start local 3 // java.lang.Throwable t1
13: .line 113
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
iconst_1
putfield jdk.internal.net.http.PullPublisher$Subscription.completed:Z
14: .line 114
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.pullScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
invokevirtual jdk.internal.net.http.common.SequentialScheduler.stop:()V
15: .line 115
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.subscriber:Ljava/util/concurrent/Flow$Subscriber;
aload 3 /* t1 */
invokeinterface java.util.concurrent.Flow$Subscriber.onError:(Ljava/lang/Throwable;)V
16: .line 116
return
end local 3 // java.lang.Throwable t1
start local 2 // java.lang.Object next
17: .line 118
StackMap locals: java.lang.Object
StackMap stack:
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.subscriber:Ljava/util/concurrent/Flow$Subscriber;
aload 2 /* next */
invokeinterface java.util.concurrent.Flow$Subscriber.onNext:(Ljava/lang/Object;)V
end local 2 // java.lang.Object next
18: .line 105
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.demand:Ljdk/internal/net/http/common/Demand;
invokevirtual jdk.internal.net.http.common.Demand.tryDecrement:()Z
ifeq 19
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.cancelled:Z
ifeq 8
19: .line 120
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.iter:Ljava/util/Iterator;
invokeinterface java.util.Iterator.hasNext:()Z
ifne 23
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.cancelled:Z
ifne 23
20: .line 121
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
iconst_1
putfield jdk.internal.net.http.PullPublisher$Subscription.completed:Z
21: .line 122
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.pullScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
invokevirtual jdk.internal.net.http.common.SequentialScheduler.stop:()V
22: .line 123
aload 0 /* this */
getfield jdk.internal.net.http.PullPublisher$Subscription$PullTask.this$1:Ljdk/internal/net/http/PullPublisher$Subscription;
getfield jdk.internal.net.http.PullPublisher$Subscription.subscriber:Ljava/util/concurrent/Flow$Subscriber;
invokeinterface java.util.concurrent.Flow$Subscriber.onComplete:()V
23: .line 125
StackMap locals:
StackMap stack:
return
end local 1 // java.lang.Throwable t
end local 0 // jdk.internal.net.http.PullPublisher$Subscription$PullTask this
LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Ljdk/internal/net/http/PullPublisher$Subscription$PullTask;
3 24 1 t Ljava/lang/Throwable;
11 12 2 next TT;
17 18 2 next TT;
13 17 3 t1 Ljava/lang/Throwable;
Exception table:
from to target type
8 9 12 Class java.lang.Throwable
10 11 12 Class java.lang.Throwable
}
SourceFile: "PullPublisher.java"
NestHost: jdk.internal.net.http.PullPublisher
InnerClasses:
public abstract Subscriber = java.util.concurrent.Flow$Subscriber of java.util.concurrent.Flow
private Subscription = jdk.internal.net.http.PullPublisher$Subscription of jdk.internal.net.http.PullPublisher
final PullTask = jdk.internal.net.http.PullPublisher$Subscription$PullTask of jdk.internal.net.http.PullPublisher$Subscription
public abstract CompleteRestartableTask = jdk.internal.net.http.common.SequentialScheduler$CompleteRestartableTask of jdk.internal.net.http.common.SequentialScheduler