public final class io.reactivex.schedulers.Schedulers
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.schedulers.Schedulers
super_class: java.lang.Object
{
static final io.reactivex.Scheduler SINGLE;
descriptor: Lio/reactivex/Scheduler;
flags: (0x0018) ACC_STATIC, ACC_FINAL
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
static final io.reactivex.Scheduler COMPUTATION;
descriptor: Lio/reactivex/Scheduler;
flags: (0x0018) ACC_STATIC, ACC_FINAL
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
static final io.reactivex.Scheduler IO;
descriptor: Lio/reactivex/Scheduler;
flags: (0x0018) ACC_STATIC, ACC_FINAL
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
static final io.reactivex.Scheduler TRAMPOLINE;
descriptor: Lio/reactivex/Scheduler;
flags: (0x0018) ACC_STATIC, ACC_FINAL
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
static final io.reactivex.Scheduler NEW_THREAD;
descriptor: Lio/reactivex/Scheduler;
flags: (0x0018) ACC_STATIC, ACC_FINAL
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new io.reactivex.schedulers.Schedulers$SingleTask
dup
invokespecial io.reactivex.schedulers.Schedulers$SingleTask.<init>:()V
invokestatic io.reactivex.plugins.RxJavaPlugins.initSingleScheduler:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
putstatic io.reactivex.schedulers.Schedulers.SINGLE:Lio/reactivex/Scheduler;
1: new io.reactivex.schedulers.Schedulers$ComputationTask
dup
invokespecial io.reactivex.schedulers.Schedulers$ComputationTask.<init>:()V
invokestatic io.reactivex.plugins.RxJavaPlugins.initComputationScheduler:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
putstatic io.reactivex.schedulers.Schedulers.COMPUTATION:Lio/reactivex/Scheduler;
2: new io.reactivex.schedulers.Schedulers$IOTask
dup
invokespecial io.reactivex.schedulers.Schedulers$IOTask.<init>:()V
invokestatic io.reactivex.plugins.RxJavaPlugins.initIoScheduler:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
putstatic io.reactivex.schedulers.Schedulers.IO:Lio/reactivex/Scheduler;
3: invokestatic io.reactivex.internal.schedulers.TrampolineScheduler.instance:()Lio/reactivex/internal/schedulers/TrampolineScheduler;
putstatic io.reactivex.schedulers.Schedulers.TRAMPOLINE:Lio/reactivex/Scheduler;
4: new io.reactivex.schedulers.Schedulers$NewThreadTask
dup
invokespecial io.reactivex.schedulers.Schedulers$NewThreadTask.<init>:()V
invokestatic io.reactivex.plugins.RxJavaPlugins.initNewThreadScheduler:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
putstatic io.reactivex.schedulers.Schedulers.NEW_THREAD:Lio/reactivex/Scheduler;
5: return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: new java.lang.IllegalStateException
dup
ldc "No instances!"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/schedulers/Schedulers;
public static io.reactivex.Scheduler computation();
descriptor: ()Lio/reactivex/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.schedulers.Schedulers.COMPUTATION:Lio/reactivex/Scheduler;
invokestatic io.reactivex.plugins.RxJavaPlugins.onComputationScheduler:(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
public static io.reactivex.Scheduler io();
descriptor: ()Lio/reactivex/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.schedulers.Schedulers.IO:Lio/reactivex/Scheduler;
invokestatic io.reactivex.plugins.RxJavaPlugins.onIoScheduler:(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
public static io.reactivex.Scheduler trampoline();
descriptor: ()Lio/reactivex/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.schedulers.Schedulers.TRAMPOLINE:Lio/reactivex/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
public static io.reactivex.Scheduler newThread();
descriptor: ()Lio/reactivex/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.schedulers.Schedulers.NEW_THREAD:Lio/reactivex/Scheduler;
invokestatic io.reactivex.plugins.RxJavaPlugins.onNewThreadScheduler:(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
public static io.reactivex.Scheduler single();
descriptor: ()Lio/reactivex/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.schedulers.Schedulers.SINGLE:Lio/reactivex/Scheduler;
invokestatic io.reactivex.plugins.RxJavaPlugins.onSingleScheduler:(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
public static io.reactivex.Scheduler from(java.util.concurrent.Executor);
descriptor: (Ljava/util/concurrent/Executor;)Lio/reactivex/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.schedulers.ExecutorScheduler
dup
aload 0
iconst_0
invokespecial io.reactivex.internal.schedulers.ExecutorScheduler.<init>:(Ljava/util/concurrent/Executor;Z)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 executor Ljava/util/concurrent/Executor;
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
RuntimeInvisibleParameterAnnotations:
0:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
executor
public static io.reactivex.Scheduler from(java.util.concurrent.Executor, boolean);
descriptor: (Ljava/util/concurrent/Executor;Z)Lio/reactivex/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.schedulers.ExecutorScheduler
dup
aload 0
iload 1
invokespecial io.reactivex.internal.schedulers.ExecutorScheduler.<init>:(Ljava/util/concurrent/Executor;Z)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 executor Ljava/util/concurrent/Executor;
0 1 1 interruptibleWorker Z
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
io.reactivex.annotations.Experimental()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
io.reactivex.annotations.Experimental()
RuntimeInvisibleParameterAnnotations:
0:
io.reactivex.annotations.NonNull()
1:
MethodParameters:
Name Flags
executor
interruptibleWorker
public static void shutdown();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.shutdown:()V
1: invokestatic io.reactivex.schedulers.Schedulers.io:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.shutdown:()V
2: invokestatic io.reactivex.schedulers.Schedulers.newThread:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.shutdown:()V
3: invokestatic io.reactivex.schedulers.Schedulers.single:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.shutdown:()V
4: invokestatic io.reactivex.schedulers.Schedulers.trampoline:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.shutdown:()V
5: invokestatic io.reactivex.internal.schedulers.SchedulerPoolFactory.shutdown:()V
6: return
LocalVariableTable:
Start End Slot Name Signature
public static void start();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.start:()V
1: invokestatic io.reactivex.schedulers.Schedulers.io:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.start:()V
2: invokestatic io.reactivex.schedulers.Schedulers.newThread:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.start:()V
3: invokestatic io.reactivex.schedulers.Schedulers.single:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.start:()V
4: invokestatic io.reactivex.schedulers.Schedulers.trampoline:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Scheduler.start:()V
5: invokestatic io.reactivex.internal.schedulers.SchedulerPoolFactory.start:()V
6: return
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "Schedulers.java"
NestMembers:
io.reactivex.schedulers.Schedulers$ComputationHolder io.reactivex.schedulers.Schedulers$ComputationTask io.reactivex.schedulers.Schedulers$IOTask io.reactivex.schedulers.Schedulers$IoHolder io.reactivex.schedulers.Schedulers$NewThreadHolder io.reactivex.schedulers.Schedulers$NewThreadTask io.reactivex.schedulers.Schedulers$SingleHolder io.reactivex.schedulers.Schedulers$SingleTask
InnerClasses:
final ComputationHolder = io.reactivex.schedulers.Schedulers$ComputationHolder of io.reactivex.schedulers.Schedulers
final ComputationTask = io.reactivex.schedulers.Schedulers$ComputationTask of io.reactivex.schedulers.Schedulers
final IOTask = io.reactivex.schedulers.Schedulers$IOTask of io.reactivex.schedulers.Schedulers
final IoHolder = io.reactivex.schedulers.Schedulers$IoHolder of io.reactivex.schedulers.Schedulers
final NewThreadHolder = io.reactivex.schedulers.Schedulers$NewThreadHolder of io.reactivex.schedulers.Schedulers
final NewThreadTask = io.reactivex.schedulers.Schedulers$NewThreadTask of io.reactivex.schedulers.Schedulers
final SingleHolder = io.reactivex.schedulers.Schedulers$SingleHolder of io.reactivex.schedulers.Schedulers
final SingleTask = io.reactivex.schedulers.Schedulers$SingleTask of io.reactivex.schedulers.Schedulers