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=2, 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 11
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 106
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 107
goto 12
10: .line 109
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.subscriber:Ljava/util/concurrent/Flow$Subscriber;
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;
invokeinterface java.util.concurrent.Flow$Subscriber.onNext:(Ljava/lang/Object;)V
11: .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 12
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
12: .line 112
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 16
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 16
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;
invokeinterface java.util.concurrent.Flow$Subscriber.onComplete:()V
16: .line 117
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 17 0 this Ljdk/internal/net/http/PullPublisher$Subscription$PullTask;
3 17 1 t Ljava/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