class org.springframework.http.server.reactive.WriteResultPublisher$State$1 extends org.springframework.http.server.reactive.WriteResultPublisher$State
minor version: 0
major version: 59
flags: flags: (0x4020) ACC_SUPER, ACC_ANNOTATION
this_class: org.springframework.http.server.reactive.WriteResultPublisher$State$1
super_class: org.springframework.http.server.reactive.WriteResultPublisher$State
{
void <init>(java.lang.String, int);
descriptor: (Ljava/lang/String;I)V
flags: (0x0000)
Code:
stack=3, locals=3, args_size=3
start local 0 0: aload 0
aload 1
iload 2
invokespecial org.springframework.http.server.reactive.WriteResultPublisher$State.<init>:(Ljava/lang/String;I)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/http/server/reactive/WriteResultPublisher$State$1;
MethodParameters:
Name Flags
$enum$name
$enum$ordinal
void subscribe(org.springframework.http.server.reactive.WriteResultPublisher, org.reactivestreams.Subscriber<? super java.lang.Void>);
descriptor: (Lorg/springframework/http/server/reactive/WriteResultPublisher;Lorg/reactivestreams/Subscriber;)V
flags: (0x0000)
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ldc "Subscriber must not be null"
invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
1: aload 1
aload 0
getstatic org.springframework.http.server.reactive.WriteResultPublisher$State$1.SUBSCRIBING:Lorg/springframework/http/server/reactive/WriteResultPublisher$State;
invokevirtual org.springframework.http.server.reactive.WriteResultPublisher.changeState:(Lorg/springframework/http/server/reactive/WriteResultPublisher$State;Lorg/springframework/http/server/reactive/WriteResultPublisher$State;)Z
ifeq 12
2: new org.springframework.http.server.reactive.WriteResultPublisher$WriteResultSubscription
dup
aload 1
invokespecial org.springframework.http.server.reactive.WriteResultPublisher$WriteResultSubscription.<init>:(Lorg/springframework/http/server/reactive/WriteResultPublisher;)V
astore 3
start local 3 3: aload 1
aload 2
putfield org.springframework.http.server.reactive.WriteResultPublisher.subscriber:Lorg/reactivestreams/Subscriber;
4: aload 2
aload 3
invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
5: aload 1
getstatic org.springframework.http.server.reactive.WriteResultPublisher$State$1.SUBSCRIBING:Lorg/springframework/http/server/reactive/WriteResultPublisher$State;
getstatic org.springframework.http.server.reactive.WriteResultPublisher$State$1.SUBSCRIBED:Lorg/springframework/http/server/reactive/WriteResultPublisher$State;
invokevirtual org.springframework.http.server.reactive.WriteResultPublisher.changeState:(Lorg/springframework/http/server/reactive/WriteResultPublisher$State;Lorg/springframework/http/server/reactive/WriteResultPublisher$State;)Z
pop
6: aload 1
getfield org.springframework.http.server.reactive.WriteResultPublisher.completedBeforeSubscribed:Z
ifeq 8
7: aload 1
invokevirtual org.springframework.http.server.reactive.WriteResultPublisher.publishComplete:()V
8: StackMap locals: org.reactivestreams.Subscription
StackMap stack:
aload 1
getfield org.springframework.http.server.reactive.WriteResultPublisher.errorBeforeSubscribed:Ljava/lang/Throwable;
astore 4
start local 4 9: aload 4
ifnull 13
10: aload 1
aload 4
invokevirtual org.springframework.http.server.reactive.WriteResultPublisher.publishError:(Ljava/lang/Throwable;)V
end local 4 end local 3 11: goto 13
12: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
aload 0
invokevirtual org.springframework.http.server.reactive.WriteResultPublisher$State$1.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
13: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/springframework/http/server/reactive/WriteResultPublisher$State$1;
0 14 1 publisher Lorg/springframework/http/server/reactive/WriteResultPublisher;
0 14 2 subscriber Lorg/reactivestreams/Subscriber<-Ljava/lang/Void;>;
3 11 3 subscription Lorg/reactivestreams/Subscription;
9 11 4 publisherError Ljava/lang/Throwable;
Signature: (Lorg/springframework/http/server/reactive/WriteResultPublisher;Lorg/reactivestreams/Subscriber<-Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
publisher
subscriber
void publishComplete(org.springframework.http.server.reactive.WriteResultPublisher);
descriptor: (Lorg/springframework/http/server/reactive/WriteResultPublisher;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
iconst_1
putfield org.springframework.http.server.reactive.WriteResultPublisher.completedBeforeSubscribed:Z
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/springframework/http/server/reactive/WriteResultPublisher$State$1;
0 2 1 publisher Lorg/springframework/http/server/reactive/WriteResultPublisher;
MethodParameters:
Name Flags
publisher
void publishError(org.springframework.http.server.reactive.WriteResultPublisher, java.lang.Throwable);
descriptor: (Lorg/springframework/http/server/reactive/WriteResultPublisher;Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 2
putfield org.springframework.http.server.reactive.WriteResultPublisher.errorBeforeSubscribed:Ljava/lang/Throwable;
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/springframework/http/server/reactive/WriteResultPublisher$State$1;
0 2 1 publisher Lorg/springframework/http/server/reactive/WriteResultPublisher;
0 2 2 ex Ljava/lang/Throwable;
MethodParameters:
Name Flags
publisher
ex
}
SourceFile: "WriteResultPublisher.java"
EnclosingMethod: org.springframework.http.server.reactive.WriteResultPublisher$State
NestHost: org.springframework.http.server.reactive.WriteResultPublisher
InnerClasses:
private State = org.springframework.http.server.reactive.WriteResultPublisher$State of org.springframework.http.server.reactive.WriteResultPublisher
org.springframework.http.server.reactive.WriteResultPublisher$State$1
private final WriteResultSubscription = org.springframework.http.server.reactive.WriteResultPublisher$WriteResultSubscription of org.springframework.http.server.reactive.WriteResultPublisher