public final class reactor.core.Disposables
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: reactor.core.Disposables
super_class: java.lang.Object
{
static final reactor.core.Disposable DISPOSED;
descriptor: Lreactor/core/Disposable;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic reactor.core.Disposables.disposed:()Lreactor/core/Disposable;
putstatic reactor.core.Disposables.DISPOSED:Lreactor/core/Disposable;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/Disposables;
public static reactor.core.Disposable$Composite composite();
descriptor: ()Lreactor/core/Disposable$Composite;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new reactor.core.Disposables$ListCompositeDisposable
dup
invokespecial reactor.core.Disposables$ListCompositeDisposable.<init>:()V
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.Disposable$Composite composite(reactor.core.Disposable[]);
descriptor: ([Lreactor/core/Disposable;)Lreactor/core/Disposable$Composite;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=3, locals=1, args_size=1
start local 0 0: new reactor.core.Disposables$ListCompositeDisposable
dup
aload 0
invokespecial reactor.core.Disposables$ListCompositeDisposable.<init>:([Lreactor/core/Disposable;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 disposables [Lreactor/core/Disposable;
MethodParameters:
Name Flags
disposables
public static reactor.core.Disposable$Composite composite(java.lang.Iterable<? extends reactor.core.Disposable>);
descriptor: (Ljava/lang/Iterable;)Lreactor/core/Disposable$Composite;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new reactor.core.Disposables$ListCompositeDisposable
dup
aload 0
invokespecial reactor.core.Disposables$ListCompositeDisposable.<init>:(Ljava/lang/Iterable;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 disposables Ljava/lang/Iterable<+Lreactor/core/Disposable;>;
Signature: (Ljava/lang/Iterable<+Lreactor/core/Disposable;>;)Lreactor/core/Disposable$Composite;
MethodParameters:
Name Flags
disposables
public static reactor.core.Disposable disposed();
descriptor: ()Lreactor/core/Disposable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new reactor.core.Disposables$AlwaysDisposable
dup
invokespecial reactor.core.Disposables$AlwaysDisposable.<init>:()V
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.Disposable never();
descriptor: ()Lreactor/core/Disposable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new reactor.core.Disposables$NeverDisposable
dup
invokespecial reactor.core.Disposables$NeverDisposable.<init>:()V
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.Disposable single();
descriptor: ()Lreactor/core/Disposable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new reactor.core.Disposables$SimpleDisposable
dup
invokespecial reactor.core.Disposables$SimpleDisposable.<init>:()V
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.Disposable$Swap swap();
descriptor: ()Lreactor/core/Disposable$Swap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new reactor.core.Disposables$SwapDisposable
dup
invokespecial reactor.core.Disposables$SwapDisposable.<init>:()V
areturn
LocalVariableTable:
Start End Slot Name Signature
static <T> boolean set(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<T, reactor.core.Disposable>, T, reactor.core.Disposable);
descriptor: (Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Lreactor/core/Disposable;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.Disposable
astore 3
start local 3 1: aload 3
getstatic reactor.core.Disposables.DISPOSED:Lreactor/core/Disposable;
if_acmpne 5
2: aload 2
ifnull 4
3: aload 2
invokeinterface reactor.core.Disposable.dispose:()V
4: StackMap locals: reactor.core.Disposable
StackMap stack:
iconst_0
ireturn
5: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 3
aload 2
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 0
6: aload 3
ifnull 8
7: aload 3
invokeinterface reactor.core.Disposable.dispose:()V
8: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 updater Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;Lreactor/core/Disposable;>;
0 9 1 holder TT;
0 9 2 newValue Lreactor/core/Disposable;
1 9 3 current Lreactor/core/Disposable;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;Lreactor/core/Disposable;>;TT;Lreactor/core/Disposable;)Z
RuntimeVisibleParameterAnnotations:
0:
1:
2:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
updater
holder
newValue
static <T> boolean replace(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<T, reactor.core.Disposable>, T, reactor.core.Disposable);
descriptor: (Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Lreactor/core/Disposable;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.Disposable
astore 3
start local 3 1: aload 3
getstatic reactor.core.Disposables.DISPOSED:Lreactor/core/Disposable;
if_acmpne 5
2: aload 2
ifnull 4
3: aload 2
invokeinterface reactor.core.Disposable.dispose:()V
4: StackMap locals: reactor.core.Disposable
StackMap stack:
iconst_0
ireturn
5: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 3
aload 2
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 0
6: iconst_1
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 updater Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;Lreactor/core/Disposable;>;
0 7 1 holder TT;
0 7 2 newValue Lreactor/core/Disposable;
1 7 3 current Lreactor/core/Disposable;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;Lreactor/core/Disposable;>;TT;Lreactor/core/Disposable;)Z
RuntimeVisibleParameterAnnotations:
0:
1:
2:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
updater
holder
newValue
static <T> boolean dispose(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<T, reactor.core.Disposable>, );
descriptor: (Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.Disposable
astore 2
start local 2 1: getstatic reactor.core.Disposables.DISPOSED:Lreactor/core/Disposable;
astore 3
start local 3 2: aload 2
aload 3
if_acmpeq 8
3: aload 0
aload 1
aload 3
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.getAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.Disposable
astore 2
4: aload 2
aload 3
if_acmpeq 8
5: aload 2
ifnull 7
6: aload 2
invokeinterface reactor.core.Disposable.dispose:()V
7: StackMap locals: reactor.core.Disposable reactor.core.Disposable
StackMap stack:
iconst_1
ireturn
8: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 updater Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;Lreactor/core/Disposable;>;
0 9 1 holder TT;
1 9 2 current Lreactor/core/Disposable;
2 9 3 d Lreactor/core/Disposable;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;Lreactor/core/Disposable;>;TT;)Z
MethodParameters:
Name Flags
updater
holder
static boolean isDisposed(reactor.core.Disposable);
descriptor: (Lreactor/core/Disposable;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic reactor.core.Disposables.DISPOSED:Lreactor/core/Disposable;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 d Lreactor/core/Disposable;
MethodParameters:
Name Flags
d
}
SourceFile: "Disposables.java"
NestMembers:
reactor.core.Disposables$AlwaysDisposable reactor.core.Disposables$ListCompositeDisposable reactor.core.Disposables$NeverDisposable reactor.core.Disposables$SimpleDisposable reactor.core.Disposables$SwapDisposable
InnerClasses:
public abstract Composite = reactor.core.Disposable$Composite of reactor.core.Disposable
public abstract Swap = reactor.core.Disposable$Swap of reactor.core.Disposable
final AlwaysDisposable = reactor.core.Disposables$AlwaysDisposable of reactor.core.Disposables
final ListCompositeDisposable = reactor.core.Disposables$ListCompositeDisposable of reactor.core.Disposables
final NeverDisposable = reactor.core.Disposables$NeverDisposable of reactor.core.Disposables
final SimpleDisposable = reactor.core.Disposables$SimpleDisposable of reactor.core.Disposables
final SwapDisposable = reactor.core.Disposables$SwapDisposable of reactor.core.Disposables