public final class io.reactivex.plugins.RxJavaPlugins
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.plugins.RxJavaPlugins
  super_class: java.lang.Object
{
  static volatile io.reactivex.functions.Consumer<? super java.lang.Throwable> errorHandler;
    descriptor: Lio/reactivex/functions/Consumer;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super java.lang.Runnable, ? extends java.lang.Runnable> onScheduleHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Ljava/lang/Runnable;+Ljava/lang/Runnable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> onInitComputationHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> onInitSingleHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> onInitIoHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> onInitNewThreadHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> onComputationHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> onSingleHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> onIoHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> onNewThreadHandler;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Flowable, ? extends io.reactivex.Flowable> onFlowableAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Flowable;+Lio/reactivex/Flowable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.flowables.ConnectableFlowable, ? extends io.reactivex.flowables.ConnectableFlowable> onConnectableFlowableAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/flowables/ConnectableFlowable;+Lio/reactivex/flowables/ConnectableFlowable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Observable, ? extends io.reactivex.Observable> onObservableAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Observable;+Lio/reactivex/Observable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.observables.ConnectableObservable, ? extends io.reactivex.observables.ConnectableObservable> onConnectableObservableAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/observables/ConnectableObservable;+Lio/reactivex/observables/ConnectableObservable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Maybe, ? extends io.reactivex.Maybe> onMaybeAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Maybe;+Lio/reactivex/Maybe;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Single, ? extends io.reactivex.Single> onSingleAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Single;+Lio/reactivex/Single;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.Completable, ? extends io.reactivex.Completable> onCompletableAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Completable;+Lio/reactivex/Completable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.Function<? super io.reactivex.parallel.ParallelFlowable, ? extends io.reactivex.parallel.ParallelFlowable> onParallelAssembly;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable;+Lio/reactivex/parallel/ParallelFlowable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.BiFunction<? super io.reactivex.Flowable, ? super org.reactivestreams.Subscriber, ? extends org.reactivestreams.Subscriber> onFlowableSubscribe;
    descriptor: Lio/reactivex/functions/BiFunction;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/BiFunction<-Lio/reactivex/Flowable;-Lorg/reactivestreams/Subscriber;+Lorg/reactivestreams/Subscriber;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.BiFunction<? super io.reactivex.Maybe, ? super io.reactivex.MaybeObserver, ? extends io.reactivex.MaybeObserver> onMaybeSubscribe;
    descriptor: Lio/reactivex/functions/BiFunction;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/BiFunction<-Lio/reactivex/Maybe;-Lio/reactivex/MaybeObserver;+Lio/reactivex/MaybeObserver;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.BiFunction<? super io.reactivex.Observable, ? super io.reactivex.Observer, ? extends io.reactivex.Observer> onObservableSubscribe;
    descriptor: Lio/reactivex/functions/BiFunction;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/BiFunction<-Lio/reactivex/Observable;-Lio/reactivex/Observer;+Lio/reactivex/Observer;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.BiFunction<? super io.reactivex.Single, ? super io.reactivex.SingleObserver, ? extends io.reactivex.SingleObserver> onSingleSubscribe;
    descriptor: Lio/reactivex/functions/BiFunction;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/BiFunction<-Lio/reactivex/Single;-Lio/reactivex/SingleObserver;+Lio/reactivex/SingleObserver;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.BiFunction<? super io.reactivex.Completable, ? super io.reactivex.CompletableObserver, ? extends io.reactivex.CompletableObserver> onCompletableSubscribe;
    descriptor: Lio/reactivex/functions/BiFunction;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    Signature: Lio/reactivex/functions/BiFunction<-Lio/reactivex/Completable;-Lio/reactivex/CompletableObserver;+Lio/reactivex/CompletableObserver;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile io.reactivex.functions.BooleanSupplier onBeforeBlocking;
    descriptor: Lio/reactivex/functions/BooleanSupplier;
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  static volatile boolean lockdown;
    descriptor: Z
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE

  static volatile boolean failNonBlockingScheduler;
    descriptor: Z
    flags: (0x0048) ACC_STATIC, ACC_VOLATILE

  public static void lockdown();
    descriptor: ()V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 133
            iconst_1
            putstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
         1: .line 134
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public static boolean isLockdown();
    descriptor: ()Z
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 141
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public static void setFailOnNonBlockingScheduler(boolean);
    descriptor: (Z)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // boolean enable
         0: .line 153
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 154
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 156
      StackMap locals:
      StackMap stack:
            iload 0 /* enable */
            putstatic io.reactivex.plugins.RxJavaPlugins.failNonBlockingScheduler:Z
         3: .line 157
            return
        end local 0 // boolean enable
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  enable  Z
    MethodParameters:
        Name  Flags
      enable  

  public static boolean isFailOnNonBlockingScheduler();
    descriptor: ()Z
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 168
            getstatic io.reactivex.plugins.RxJavaPlugins.failNonBlockingScheduler:Z
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public static io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> getComputationSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 177
            getstatic io.reactivex.plugins.RxJavaPlugins.onComputationHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Consumer<? super java.lang.Throwable> getErrorHandler();
    descriptor: ()Lio/reactivex/functions/Consumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 186
            getstatic io.reactivex.plugins.RxJavaPlugins.errorHandler:Lio/reactivex/functions/Consumer;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> getInitComputationSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 195
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitComputationHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> getInitIoSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 204
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitIoHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> getInitNewThreadSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 213
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitNewThreadHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler> getInitSingleSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 222
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitSingleHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> getIoSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 231
            getstatic io.reactivex.plugins.RxJavaPlugins.onIoHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> getNewThreadSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 240
            getstatic io.reactivex.plugins.RxJavaPlugins.onNewThreadHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super java.lang.Runnable, ? extends java.lang.Runnable> getScheduleHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 249
            getstatic io.reactivex.plugins.RxJavaPlugins.onScheduleHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Ljava/lang/Runnable;+Ljava/lang/Runnable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler> getSingleSchedulerHandler();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 258
            getstatic io.reactivex.plugins.RxJavaPlugins.onSingleHandler:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.Scheduler initComputationScheduler(java.util.concurrent.Callable<io.reactivex.Scheduler>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.util.concurrent.Callable defaultScheduler
         0: .line 269
            aload 0 /* defaultScheduler */
            ldc "Scheduler Callable can't be null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 270
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitComputationHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         2: .line 271
            aload 1 /* f */
            ifnonnull 4
         3: .line 272
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.callRequireNonNull:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
         4: .line 274
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.applyRequireNonNull:(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // java.util.concurrent.Callable defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    5     0  defaultScheduler  Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;
            2    5     1                 f  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;)Lio/reactivex/Scheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static io.reactivex.Scheduler initIoScheduler(java.util.concurrent.Callable<io.reactivex.Scheduler>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.util.concurrent.Callable defaultScheduler
         0: .line 285
            aload 0 /* defaultScheduler */
            ldc "Scheduler Callable can't be null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 286
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitIoHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         2: .line 287
            aload 1 /* f */
            ifnonnull 4
         3: .line 288
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.callRequireNonNull:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
         4: .line 290
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.applyRequireNonNull:(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // java.util.concurrent.Callable defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    5     0  defaultScheduler  Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;
            2    5     1                 f  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;)Lio/reactivex/Scheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static io.reactivex.Scheduler initNewThreadScheduler(java.util.concurrent.Callable<io.reactivex.Scheduler>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.util.concurrent.Callable defaultScheduler
         0: .line 301
            aload 0 /* defaultScheduler */
            ldc "Scheduler Callable can't be null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 302
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitNewThreadHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         2: .line 303
            aload 1 /* f */
            ifnonnull 4
         3: .line 304
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.callRequireNonNull:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
         4: .line 306
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.applyRequireNonNull:(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // java.util.concurrent.Callable defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    5     0  defaultScheduler  Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;
            2    5     1                 f  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;)Lio/reactivex/Scheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static io.reactivex.Scheduler initSingleScheduler(java.util.concurrent.Callable<io.reactivex.Scheduler>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.util.concurrent.Callable defaultScheduler
         0: .line 317
            aload 0 /* defaultScheduler */
            ldc "Scheduler Callable can't be null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 318
            getstatic io.reactivex.plugins.RxJavaPlugins.onInitSingleHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         2: .line 319
            aload 1 /* f */
            ifnonnull 4
         3: .line 320
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.callRequireNonNull:(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
         4: .line 322
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.applyRequireNonNull:(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // java.util.concurrent.Callable defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    5     0  defaultScheduler  Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;
            2    5     1                 f  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;)Lio/reactivex/Scheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static io.reactivex.Scheduler onComputationScheduler(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Scheduler defaultScheduler
         0: .line 332
            getstatic io.reactivex.plugins.RxJavaPlugins.onComputationHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 333
            aload 1 /* f */
            ifnonnull 3
         2: .line 334
            aload 0 /* defaultScheduler */
            areturn
         3: .line 336
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Scheduler defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0  defaultScheduler  Lio/reactivex/Scheduler;
            1    4     1                 f  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static void onError(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // java.lang.Throwable error
         0: .line 361
            getstatic io.reactivex.plugins.RxJavaPlugins.errorHandler:Lio/reactivex/functions/Consumer;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Consumer f
         1: .line 363
            aload 0 /* error */
            ifnonnull 4
         2: .line 364
            new java.lang.NullPointerException
            dup
            ldc "onError called with null. Null values are generally not allowed in 2.x operators and sources."
            invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
            astore 0 /* error */
         3: .line 365
            goto 6
         4: .line 366
      StackMap locals: io.reactivex.functions.Consumer
      StackMap stack:
            aload 0 /* error */
            invokestatic io.reactivex.plugins.RxJavaPlugins.isBug:(Ljava/lang/Throwable;)Z
            ifne 6
         5: .line 367
            new io.reactivex.exceptions.UndeliverableException
            dup
            aload 0 /* error */
            invokespecial io.reactivex.exceptions.UndeliverableException.<init>:(Ljava/lang/Throwable;)V
            astore 0 /* error */
         6: .line 371
      StackMap locals:
      StackMap stack:
            aload 1 /* f */
            ifnull 12
         7: .line 373
            aload 1 /* f */
            aload 0 /* error */
            invokeinterface io.reactivex.functions.Consumer.accept:(Ljava/lang/Object;)V
         8: .line 374
            return
         9: .line 375
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* e */
        start local 2 // java.lang.Throwable e
        10: .line 377
            aload 2 /* e */
            invokevirtual java.lang.Throwable.printStackTrace:()V
        11: .line 378
            aload 2 /* e */
            invokestatic io.reactivex.plugins.RxJavaPlugins.uncaught:(Ljava/lang/Throwable;)V
        end local 2 // java.lang.Throwable e
        12: .line 382
      StackMap locals:
      StackMap stack:
            aload 0 /* error */
            invokevirtual java.lang.Throwable.printStackTrace:()V
        13: .line 383
            aload 0 /* error */
            invokestatic io.reactivex.plugins.RxJavaPlugins.uncaught:(Ljava/lang/Throwable;)V
        14: .line 384
            return
        end local 1 // io.reactivex.functions.Consumer f
        end local 0 // java.lang.Throwable error
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   15     0  error  Ljava/lang/Throwable;
            1   15     1      f  Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
           10   12     2      e  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           7     8       9  Class java.lang.Throwable
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      error  

  static boolean isBug(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Z
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.lang.Throwable error
         0: .line 396
            aload 0 /* error */
            instanceof io.reactivex.exceptions.OnErrorNotImplementedException
            ifeq 2
         1: .line 397
            iconst_1
            ireturn
         2: .line 401
      StackMap locals:
      StackMap stack:
            aload 0 /* error */
            instanceof io.reactivex.exceptions.MissingBackpressureException
            ifeq 4
         3: .line 402
            iconst_1
            ireturn
         4: .line 406
      StackMap locals:
      StackMap stack:
            aload 0 /* error */
            instanceof java.lang.IllegalStateException
            ifeq 6
         5: .line 407
            iconst_1
            ireturn
         6: .line 411
      StackMap locals:
      StackMap stack:
            aload 0 /* error */
            instanceof java.lang.NullPointerException
            ifeq 8
         7: .line 412
            iconst_1
            ireturn
         8: .line 415
      StackMap locals:
      StackMap stack:
            aload 0 /* error */
            instanceof java.lang.IllegalArgumentException
            ifeq 10
         9: .line 416
            iconst_1
            ireturn
        10: .line 419
      StackMap locals:
      StackMap stack:
            aload 0 /* error */
            instanceof io.reactivex.exceptions.CompositeException
            ifeq 12
        11: .line 420
            iconst_1
            ireturn
        12: .line 423
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 0 // java.lang.Throwable error
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   13     0  error  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      error  

  static void uncaught(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // java.lang.Throwable error
         0: .line 427
            invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
            astore 1 /* currentThread */
        start local 1 // java.lang.Thread currentThread
         1: .line 428
            aload 1 /* currentThread */
            invokevirtual java.lang.Thread.getUncaughtExceptionHandler:()Ljava/lang/Thread$UncaughtExceptionHandler;
            astore 2 /* handler */
        start local 2 // java.lang.Thread$UncaughtExceptionHandler handler
         2: .line 429
            aload 2 /* handler */
            aload 1 /* currentThread */
            aload 0 /* error */
            invokeinterface java.lang.Thread$UncaughtExceptionHandler.uncaughtException:(Ljava/lang/Thread;Ljava/lang/Throwable;)V
         3: .line 430
            return
        end local 2 // java.lang.Thread$UncaughtExceptionHandler handler
        end local 1 // java.lang.Thread currentThread
        end local 0 // java.lang.Throwable error
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    4     0          error  Ljava/lang/Throwable;
            1    4     1  currentThread  Ljava/lang/Thread;
            2    4     2        handler  Ljava/lang/Thread$UncaughtExceptionHandler;
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      error  

  public static io.reactivex.Scheduler onIoScheduler(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Scheduler defaultScheduler
         0: .line 439
            getstatic io.reactivex.plugins.RxJavaPlugins.onIoHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 440
            aload 1 /* f */
            ifnonnull 3
         2: .line 441
            aload 0 /* defaultScheduler */
            areturn
         3: .line 443
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Scheduler defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0  defaultScheduler  Lio/reactivex/Scheduler;
            1    4     1                 f  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static io.reactivex.Scheduler onNewThreadScheduler(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Scheduler defaultScheduler
         0: .line 453
            getstatic io.reactivex.plugins.RxJavaPlugins.onNewThreadHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 454
            aload 1 /* f */
            ifnonnull 3
         2: .line 455
            aload 0 /* defaultScheduler */
            areturn
         3: .line 457
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Scheduler defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0  defaultScheduler  Lio/reactivex/Scheduler;
            1    4     1                 f  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static java.lang.Runnable onSchedule(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)Ljava/lang/Runnable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.lang.Runnable run
         0: .line 467
            aload 0 /* run */
            ldc "run is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 469
            getstatic io.reactivex.plugins.RxJavaPlugins.onScheduleHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         2: .line 470
            aload 1 /* f */
            ifnonnull 4
         3: .line 471
            aload 0 /* run */
            areturn
         4: .line 473
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* run */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.Runnable
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // java.lang.Runnable run
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0   run  Ljava/lang/Runnable;
            2    5     1     f  Lio/reactivex/functions/Function<-Ljava/lang/Runnable;+Ljava/lang/Runnable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      run   

  public static io.reactivex.Scheduler onSingleScheduler(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Scheduler defaultScheduler
         0: .line 483
            getstatic io.reactivex.plugins.RxJavaPlugins.onSingleHandler:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 484
            aload 1 /* f */
            ifnonnull 3
         2: .line 485
            aload 0 /* defaultScheduler */
            areturn
         3: .line 487
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 1 /* f */
            aload 0 /* defaultScheduler */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Scheduler defaultScheduler
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0  defaultScheduler  Lio/reactivex/Scheduler;
            1    4     1                 f  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      defaultScheduler  

  public static void reset();
    descriptor: ()V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 494
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setErrorHandler:(Lio/reactivex/functions/Consumer;)V
         1: .line 495
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setScheduleHandler:(Lio/reactivex/functions/Function;)V
         2: .line 497
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setComputationSchedulerHandler:(Lio/reactivex/functions/Function;)V
         3: .line 498
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setInitComputationSchedulerHandler:(Lio/reactivex/functions/Function;)V
         4: .line 500
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setIoSchedulerHandler:(Lio/reactivex/functions/Function;)V
         5: .line 501
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setInitIoSchedulerHandler:(Lio/reactivex/functions/Function;)V
         6: .line 503
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setSingleSchedulerHandler:(Lio/reactivex/functions/Function;)V
         7: .line 504
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setInitSingleSchedulerHandler:(Lio/reactivex/functions/Function;)V
         8: .line 506
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setNewThreadSchedulerHandler:(Lio/reactivex/functions/Function;)V
         9: .line 507
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setInitNewThreadSchedulerHandler:(Lio/reactivex/functions/Function;)V
        10: .line 509
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnFlowableAssembly:(Lio/reactivex/functions/Function;)V
        11: .line 510
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnFlowableSubscribe:(Lio/reactivex/functions/BiFunction;)V
        12: .line 512
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnObservableAssembly:(Lio/reactivex/functions/Function;)V
        13: .line 513
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnObservableSubscribe:(Lio/reactivex/functions/BiFunction;)V
        14: .line 515
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnSingleAssembly:(Lio/reactivex/functions/Function;)V
        15: .line 516
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnSingleSubscribe:(Lio/reactivex/functions/BiFunction;)V
        16: .line 518
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnCompletableAssembly:(Lio/reactivex/functions/Function;)V
        17: .line 519
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnCompletableSubscribe:(Lio/reactivex/functions/BiFunction;)V
        18: .line 521
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnConnectableFlowableAssembly:(Lio/reactivex/functions/Function;)V
        19: .line 522
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnConnectableObservableAssembly:(Lio/reactivex/functions/Function;)V
        20: .line 524
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnMaybeAssembly:(Lio/reactivex/functions/Function;)V
        21: .line 525
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnMaybeSubscribe:(Lio/reactivex/functions/BiFunction;)V
        22: .line 527
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnParallelAssembly:(Lio/reactivex/functions/Function;)V
        23: .line 529
            iconst_0
            invokestatic io.reactivex.plugins.RxJavaPlugins.setFailOnNonBlockingScheduler:(Z)V
        24: .line 530
            aconst_null
            invokestatic io.reactivex.plugins.RxJavaPlugins.setOnBeforeBlocking:(Lio/reactivex/functions/BooleanSupplier;)V
        25: .line 531
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public static void setComputationSchedulerHandler(io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 538
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 539
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 541
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onComputationHandler:Lio/reactivex/functions/Function;
         3: .line 542
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setErrorHandler(io.reactivex.functions.Consumer<? super java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/Consumer;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Consumer handler
         0: .line 549
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 550
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 552
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.errorHandler:Lio/reactivex/functions/Consumer;
         3: .line 553
            return
        end local 0 // io.reactivex.functions.Consumer handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
    Signature: (Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setInitComputationSchedulerHandler(io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 560
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 561
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 563
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onInitComputationHandler:Lio/reactivex/functions/Function;
         3: .line 564
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setInitIoSchedulerHandler(io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 571
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 572
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 574
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onInitIoHandler:Lio/reactivex/functions/Function;
         3: .line 575
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setInitNewThreadSchedulerHandler(io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 582
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 583
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 585
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onInitNewThreadHandler:Lio/reactivex/functions/Function;
         3: .line 586
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setInitSingleSchedulerHandler(io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 593
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 594
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 596
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onInitSingleHandler:Lio/reactivex/functions/Function;
         3: .line 597
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setIoSchedulerHandler(io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 604
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 605
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 607
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onIoHandler:Lio/reactivex/functions/Function;
         3: .line 608
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setNewThreadSchedulerHandler(io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 615
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 616
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 618
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onNewThreadHandler:Lio/reactivex/functions/Function;
         3: .line 619
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setScheduleHandler(io.reactivex.functions.Function<? super java.lang.Runnable, ? extends java.lang.Runnable>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 626
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 627
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 629
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onScheduleHandler:Lio/reactivex/functions/Function;
         3: .line 630
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Ljava/lang/Runnable;+Ljava/lang/Runnable;>;
    Signature: (Lio/reactivex/functions/Function<-Ljava/lang/Runnable;+Ljava/lang/Runnable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static void setSingleSchedulerHandler(io.reactivex.functions.Function<? super io.reactivex.Scheduler, ? extends io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 637
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 638
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 640
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onSingleHandler:Lio/reactivex/functions/Function;
         3: .line 641
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  static void unlock();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 647
            iconst_0
            putstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
         1: .line 648
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public static io.reactivex.functions.Function<? super io.reactivex.Completable, ? extends io.reactivex.Completable> getOnCompletableAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 656
            getstatic io.reactivex.plugins.RxJavaPlugins.onCompletableAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Completable;+Lio/reactivex/Completable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.BiFunction<? super io.reactivex.Completable, ? super io.reactivex.CompletableObserver, ? extends io.reactivex.CompletableObserver> getOnCompletableSubscribe();
    descriptor: ()Lio/reactivex/functions/BiFunction;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 665
            getstatic io.reactivex.plugins.RxJavaPlugins.onCompletableSubscribe:Lio/reactivex/functions/BiFunction;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/BiFunction<-Lio/reactivex/Completable;-Lio/reactivex/CompletableObserver;+Lio/reactivex/CompletableObserver;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.Flowable, ? extends io.reactivex.Flowable> getOnFlowableAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 675
            getstatic io.reactivex.plugins.RxJavaPlugins.onFlowableAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Flowable;+Lio/reactivex/Flowable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.flowables.ConnectableFlowable, ? extends io.reactivex.flowables.ConnectableFlowable> getOnConnectableFlowableAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 685
            getstatic io.reactivex.plugins.RxJavaPlugins.onConnectableFlowableAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/flowables/ConnectableFlowable;+Lio/reactivex/flowables/ConnectableFlowable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.BiFunction<? super io.reactivex.Flowable, ? super org.reactivestreams.Subscriber, ? extends org.reactivestreams.Subscriber> getOnFlowableSubscribe();
    descriptor: ()Lio/reactivex/functions/BiFunction;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 695
            getstatic io.reactivex.plugins.RxJavaPlugins.onFlowableSubscribe:Lio/reactivex/functions/BiFunction;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/BiFunction<-Lio/reactivex/Flowable;-Lorg/reactivestreams/Subscriber;+Lorg/reactivestreams/Subscriber;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.BiFunction<? super io.reactivex.Maybe, ? super io.reactivex.MaybeObserver, ? extends io.reactivex.MaybeObserver> getOnMaybeSubscribe();
    descriptor: ()Lio/reactivex/functions/BiFunction;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 705
            getstatic io.reactivex.plugins.RxJavaPlugins.onMaybeSubscribe:Lio/reactivex/functions/BiFunction;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/BiFunction<-Lio/reactivex/Maybe;-Lio/reactivex/MaybeObserver;+Lio/reactivex/MaybeObserver;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.Maybe, ? extends io.reactivex.Maybe> getOnMaybeAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 715
            getstatic io.reactivex.plugins.RxJavaPlugins.onMaybeAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Maybe;+Lio/reactivex/Maybe;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.Single, ? extends io.reactivex.Single> getOnSingleAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 725
            getstatic io.reactivex.plugins.RxJavaPlugins.onSingleAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Single;+Lio/reactivex/Single;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.BiFunction<? super io.reactivex.Single, ? super io.reactivex.SingleObserver, ? extends io.reactivex.SingleObserver> getOnSingleSubscribe();
    descriptor: ()Lio/reactivex/functions/BiFunction;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 735
            getstatic io.reactivex.plugins.RxJavaPlugins.onSingleSubscribe:Lio/reactivex/functions/BiFunction;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/BiFunction<-Lio/reactivex/Single;-Lio/reactivex/SingleObserver;+Lio/reactivex/SingleObserver;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.Observable, ? extends io.reactivex.Observable> getOnObservableAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 745
            getstatic io.reactivex.plugins.RxJavaPlugins.onObservableAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/Observable;+Lio/reactivex/Observable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.Function<? super io.reactivex.observables.ConnectableObservable, ? extends io.reactivex.observables.ConnectableObservable> getOnConnectableObservableAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 755
            getstatic io.reactivex.plugins.RxJavaPlugins.onConnectableObservableAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/observables/ConnectableObservable;+Lio/reactivex/observables/ConnectableObservable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.functions.BiFunction<? super io.reactivex.Observable, ? super io.reactivex.Observer, ? extends io.reactivex.Observer> getOnObservableSubscribe();
    descriptor: ()Lio/reactivex/functions/BiFunction;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 765
            getstatic io.reactivex.plugins.RxJavaPlugins.onObservableSubscribe:Lio/reactivex/functions/BiFunction;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/BiFunction<-Lio/reactivex/Observable;-Lio/reactivex/Observer;+Lio/reactivex/Observer;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static void setOnCompletableAssembly(io.reactivex.functions.Function<? super io.reactivex.Completable, ? extends io.reactivex.Completable>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function onCompletableAssembly
         0: .line 773
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 774
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 776
      StackMap locals:
      StackMap stack:
            aload 0 /* onCompletableAssembly */
            putstatic io.reactivex.plugins.RxJavaPlugins.onCompletableAssembly:Lio/reactivex/functions/Function;
         3: .line 777
            return
        end local 0 // io.reactivex.functions.Function onCompletableAssembly
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0    4     0  onCompletableAssembly  Lio/reactivex/functions/Function<-Lio/reactivex/Completable;+Lio/reactivex/Completable;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Completable;+Lio/reactivex/Completable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                       Name  Flags
      onCompletableAssembly  

  public static void setOnCompletableSubscribe(io.reactivex.functions.BiFunction<? super io.reactivex.Completable, ? super io.reactivex.CompletableObserver, ? extends io.reactivex.CompletableObserver>);
    descriptor: (Lio/reactivex/functions/BiFunction;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.BiFunction onCompletableSubscribe
         0: .line 785
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 786
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 788
      StackMap locals:
      StackMap stack:
            aload 0 /* onCompletableSubscribe */
            putstatic io.reactivex.plugins.RxJavaPlugins.onCompletableSubscribe:Lio/reactivex/functions/BiFunction;
         3: .line 789
            return
        end local 0 // io.reactivex.functions.BiFunction onCompletableSubscribe
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0    4     0  onCompletableSubscribe  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Completable;-Lio/reactivex/CompletableObserver;+Lio/reactivex/CompletableObserver;>;
    Signature: (Lio/reactivex/functions/BiFunction<-Lio/reactivex/Completable;-Lio/reactivex/CompletableObserver;+Lio/reactivex/CompletableObserver;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                        Name  Flags
      onCompletableSubscribe  

  public static void setOnFlowableAssembly(io.reactivex.functions.Function<? super io.reactivex.Flowable, ? extends io.reactivex.Flowable>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function onFlowableAssembly
         0: .line 797
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 798
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 800
      StackMap locals:
      StackMap stack:
            aload 0 /* onFlowableAssembly */
            putstatic io.reactivex.plugins.RxJavaPlugins.onFlowableAssembly:Lio/reactivex/functions/Function;
         3: .line 801
            return
        end local 0 // io.reactivex.functions.Function onFlowableAssembly
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    4     0  onFlowableAssembly  Lio/reactivex/functions/Function<-Lio/reactivex/Flowable;+Lio/reactivex/Flowable;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Flowable;+Lio/reactivex/Flowable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                    Name  Flags
      onFlowableAssembly  

  public static void setOnMaybeAssembly(io.reactivex.functions.Function<? super io.reactivex.Maybe, ? extends io.reactivex.Maybe>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function onMaybeAssembly
         0: .line 809
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 810
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 812
      StackMap locals:
      StackMap stack:
            aload 0 /* onMaybeAssembly */
            putstatic io.reactivex.plugins.RxJavaPlugins.onMaybeAssembly:Lio/reactivex/functions/Function;
         3: .line 813
            return
        end local 0 // io.reactivex.functions.Function onMaybeAssembly
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    4     0  onMaybeAssembly  Lio/reactivex/functions/Function<-Lio/reactivex/Maybe;+Lio/reactivex/Maybe;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Maybe;+Lio/reactivex/Maybe;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                 Name  Flags
      onMaybeAssembly  

  public static void setOnConnectableFlowableAssembly(io.reactivex.functions.Function<? super io.reactivex.flowables.ConnectableFlowable, ? extends io.reactivex.flowables.ConnectableFlowable>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function onConnectableFlowableAssembly
         0: .line 821
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 822
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 824
      StackMap locals:
      StackMap stack:
            aload 0 /* onConnectableFlowableAssembly */
            putstatic io.reactivex.plugins.RxJavaPlugins.onConnectableFlowableAssembly:Lio/reactivex/functions/Function;
         3: .line 825
            return
        end local 0 // io.reactivex.functions.Function onConnectableFlowableAssembly
      LocalVariableTable:
        Start  End  Slot                           Name  Signature
            0    4     0  onConnectableFlowableAssembly  Lio/reactivex/functions/Function<-Lio/reactivex/flowables/ConnectableFlowable;+Lio/reactivex/flowables/ConnectableFlowable;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/flowables/ConnectableFlowable;+Lio/reactivex/flowables/ConnectableFlowable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                               Name  Flags
      onConnectableFlowableAssembly  

  public static void setOnFlowableSubscribe(io.reactivex.functions.BiFunction<? super io.reactivex.Flowable, ? super org.reactivestreams.Subscriber, ? extends org.reactivestreams.Subscriber>);
    descriptor: (Lio/reactivex/functions/BiFunction;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.BiFunction onFlowableSubscribe
         0: .line 833
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 834
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 836
      StackMap locals:
      StackMap stack:
            aload 0 /* onFlowableSubscribe */
            putstatic io.reactivex.plugins.RxJavaPlugins.onFlowableSubscribe:Lio/reactivex/functions/BiFunction;
         3: .line 837
            return
        end local 0 // io.reactivex.functions.BiFunction onFlowableSubscribe
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    4     0  onFlowableSubscribe  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Flowable;-Lorg/reactivestreams/Subscriber;+Lorg/reactivestreams/Subscriber;>;
    Signature: (Lio/reactivex/functions/BiFunction<-Lio/reactivex/Flowable;-Lorg/reactivestreams/Subscriber;+Lorg/reactivestreams/Subscriber;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                     Name  Flags
      onFlowableSubscribe  

  public static void setOnMaybeSubscribe(io.reactivex.functions.BiFunction<? super io.reactivex.Maybe, io.reactivex.MaybeObserver, ? extends io.reactivex.MaybeObserver>);
    descriptor: (Lio/reactivex/functions/BiFunction;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.BiFunction onMaybeSubscribe
         0: .line 845
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 846
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 848
      StackMap locals:
      StackMap stack:
            aload 0 /* onMaybeSubscribe */
            putstatic io.reactivex.plugins.RxJavaPlugins.onMaybeSubscribe:Lio/reactivex/functions/BiFunction;
         3: .line 849
            return
        end local 0 // io.reactivex.functions.BiFunction onMaybeSubscribe
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0  onMaybeSubscribe  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Maybe;Lio/reactivex/MaybeObserver;+Lio/reactivex/MaybeObserver;>;
    Signature: (Lio/reactivex/functions/BiFunction<-Lio/reactivex/Maybe;Lio/reactivex/MaybeObserver;+Lio/reactivex/MaybeObserver;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                  Name  Flags
      onMaybeSubscribe  

  public static void setOnObservableAssembly(io.reactivex.functions.Function<? super io.reactivex.Observable, ? extends io.reactivex.Observable>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function onObservableAssembly
         0: .line 857
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 858
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 860
      StackMap locals:
      StackMap stack:
            aload 0 /* onObservableAssembly */
            putstatic io.reactivex.plugins.RxJavaPlugins.onObservableAssembly:Lio/reactivex/functions/Function;
         3: .line 861
            return
        end local 0 // io.reactivex.functions.Function onObservableAssembly
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0    4     0  onObservableAssembly  Lio/reactivex/functions/Function<-Lio/reactivex/Observable;+Lio/reactivex/Observable;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Observable;+Lio/reactivex/Observable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                      Name  Flags
      onObservableAssembly  

  public static void setOnConnectableObservableAssembly(io.reactivex.functions.Function<? super io.reactivex.observables.ConnectableObservable, ? extends io.reactivex.observables.ConnectableObservable>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function onConnectableObservableAssembly
         0: .line 869
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 870
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 872
      StackMap locals:
      StackMap stack:
            aload 0 /* onConnectableObservableAssembly */
            putstatic io.reactivex.plugins.RxJavaPlugins.onConnectableObservableAssembly:Lio/reactivex/functions/Function;
         3: .line 873
            return
        end local 0 // io.reactivex.functions.Function onConnectableObservableAssembly
      LocalVariableTable:
        Start  End  Slot                             Name  Signature
            0    4     0  onConnectableObservableAssembly  Lio/reactivex/functions/Function<-Lio/reactivex/observables/ConnectableObservable;+Lio/reactivex/observables/ConnectableObservable;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/observables/ConnectableObservable;+Lio/reactivex/observables/ConnectableObservable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                                 Name  Flags
      onConnectableObservableAssembly  

  public static void setOnObservableSubscribe(io.reactivex.functions.BiFunction<? super io.reactivex.Observable, ? super io.reactivex.Observer, ? extends io.reactivex.Observer>);
    descriptor: (Lio/reactivex/functions/BiFunction;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.BiFunction onObservableSubscribe
         0: .line 882
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 883
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 885
      StackMap locals:
      StackMap stack:
            aload 0 /* onObservableSubscribe */
            putstatic io.reactivex.plugins.RxJavaPlugins.onObservableSubscribe:Lio/reactivex/functions/BiFunction;
         3: .line 886
            return
        end local 0 // io.reactivex.functions.BiFunction onObservableSubscribe
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0    4     0  onObservableSubscribe  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Observable;-Lio/reactivex/Observer;+Lio/reactivex/Observer;>;
    Signature: (Lio/reactivex/functions/BiFunction<-Lio/reactivex/Observable;-Lio/reactivex/Observer;+Lio/reactivex/Observer;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                       Name  Flags
      onObservableSubscribe  

  public static void setOnSingleAssembly(io.reactivex.functions.Function<? super io.reactivex.Single, ? extends io.reactivex.Single>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function onSingleAssembly
         0: .line 894
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 895
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 897
      StackMap locals:
      StackMap stack:
            aload 0 /* onSingleAssembly */
            putstatic io.reactivex.plugins.RxJavaPlugins.onSingleAssembly:Lio/reactivex/functions/Function;
         3: .line 898
            return
        end local 0 // io.reactivex.functions.Function onSingleAssembly
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0  onSingleAssembly  Lio/reactivex/functions/Function<-Lio/reactivex/Single;+Lio/reactivex/Single;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Single;+Lio/reactivex/Single;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                  Name  Flags
      onSingleAssembly  

  public static void setOnSingleSubscribe(io.reactivex.functions.BiFunction<? super io.reactivex.Single, ? super io.reactivex.SingleObserver, ? extends io.reactivex.SingleObserver>);
    descriptor: (Lio/reactivex/functions/BiFunction;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.BiFunction onSingleSubscribe
         0: .line 906
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 907
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 909
      StackMap locals:
      StackMap stack:
            aload 0 /* onSingleSubscribe */
            putstatic io.reactivex.plugins.RxJavaPlugins.onSingleSubscribe:Lio/reactivex/functions/BiFunction;
         3: .line 910
            return
        end local 0 // io.reactivex.functions.BiFunction onSingleSubscribe
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    4     0  onSingleSubscribe  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Single;-Lio/reactivex/SingleObserver;+Lio/reactivex/SingleObserver;>;
    Signature: (Lio/reactivex/functions/BiFunction<-Lio/reactivex/Single;-Lio/reactivex/SingleObserver;+Lio/reactivex/SingleObserver;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
                   Name  Flags
      onSingleSubscribe  

  public static <T> org.reactivestreams.Subscriber<? super T> onSubscribe(io.reactivex.Flowable<T>, org.reactivestreams.Subscriber<? super T>);
    descriptor: (Lio/reactivex/Flowable;Lorg/reactivestreams/Subscriber;)Lorg/reactivestreams/Subscriber;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Flowable source
        start local 1 // org.reactivestreams.Subscriber subscriber
         0: .line 922
            getstatic io.reactivex.plugins.RxJavaPlugins.onFlowableSubscribe:Lio/reactivex/functions/BiFunction;
            astore 2 /* f */
        start local 2 // io.reactivex.functions.BiFunction f
         1: .line 923
            aload 2 /* f */
            ifnull 3
         2: .line 924
            aload 2 /* f */
            aload 0 /* source */
            aload 1 /* subscriber */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.reactivestreams.Subscriber
            areturn
         3: .line 926
      StackMap locals: io.reactivex.functions.BiFunction
      StackMap stack:
            aload 1 /* subscriber */
            areturn
        end local 2 // io.reactivex.functions.BiFunction f
        end local 1 // org.reactivestreams.Subscriber subscriber
        end local 0 // io.reactivex.Flowable source
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0      source  Lio/reactivex/Flowable<TT;>;
            0    4     1  subscriber  Lorg/reactivestreams/Subscriber<-TT;>;
            1    4     2           f  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Flowable;-Lorg/reactivestreams/Subscriber;+Lorg/reactivestreams/Subscriber;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Flowable<TT;>;Lorg/reactivestreams/Subscriber<-TT;>;)Lorg/reactivestreams/Subscriber<-TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      source      
      subscriber  

  public static <T> io.reactivex.Observer<? super T> onSubscribe(io.reactivex.Observable<T>, io.reactivex.Observer<? super T>);
    descriptor: (Lio/reactivex/Observable;Lio/reactivex/Observer;)Lio/reactivex/Observer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Observable source
        start local 1 // io.reactivex.Observer observer
         0: .line 939
            getstatic io.reactivex.plugins.RxJavaPlugins.onObservableSubscribe:Lio/reactivex/functions/BiFunction;
            astore 2 /* f */
        start local 2 // io.reactivex.functions.BiFunction f
         1: .line 940
            aload 2 /* f */
            ifnull 3
         2: .line 941
            aload 2 /* f */
            aload 0 /* source */
            aload 1 /* observer */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Observer
            areturn
         3: .line 943
      StackMap locals: io.reactivex.functions.BiFunction
      StackMap stack:
            aload 1 /* observer */
            areturn
        end local 2 // io.reactivex.functions.BiFunction f
        end local 1 // io.reactivex.Observer observer
        end local 0 // io.reactivex.Observable source
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0    source  Lio/reactivex/Observable<TT;>;
            0    4     1  observer  Lio/reactivex/Observer<-TT;>;
            1    4     2         f  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Observable;-Lio/reactivex/Observer;+Lio/reactivex/Observer;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Observable<TT;>;Lio/reactivex/Observer<-TT;>;)Lio/reactivex/Observer<-TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      source    
      observer  

  public static <T> io.reactivex.SingleObserver<? super T> onSubscribe(io.reactivex.Single<T>, io.reactivex.SingleObserver<? super T>);
    descriptor: (Lio/reactivex/Single;Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Single source
        start local 1 // io.reactivex.SingleObserver observer
         0: .line 956
            getstatic io.reactivex.plugins.RxJavaPlugins.onSingleSubscribe:Lio/reactivex/functions/BiFunction;
            astore 2 /* f */
        start local 2 // io.reactivex.functions.BiFunction f
         1: .line 957
            aload 2 /* f */
            ifnull 3
         2: .line 958
            aload 2 /* f */
            aload 0 /* source */
            aload 1 /* observer */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.SingleObserver
            areturn
         3: .line 960
      StackMap locals: io.reactivex.functions.BiFunction
      StackMap stack:
            aload 1 /* observer */
            areturn
        end local 2 // io.reactivex.functions.BiFunction f
        end local 1 // io.reactivex.SingleObserver observer
        end local 0 // io.reactivex.Single source
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0    source  Lio/reactivex/Single<TT;>;
            0    4     1  observer  Lio/reactivex/SingleObserver<-TT;>;
            1    4     2         f  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Single;-Lio/reactivex/SingleObserver;+Lio/reactivex/SingleObserver;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Single<TT;>;Lio/reactivex/SingleObserver<-TT;>;)Lio/reactivex/SingleObserver<-TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      source    
      observer  

  public static io.reactivex.CompletableObserver onSubscribe(io.reactivex.Completable, io.reactivex.CompletableObserver);
    descriptor: (Lio/reactivex/Completable;Lio/reactivex/CompletableObserver;)Lio/reactivex/CompletableObserver;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Completable source
        start local 1 // io.reactivex.CompletableObserver observer
         0: .line 971
            getstatic io.reactivex.plugins.RxJavaPlugins.onCompletableSubscribe:Lio/reactivex/functions/BiFunction;
            astore 2 /* f */
        start local 2 // io.reactivex.functions.BiFunction f
         1: .line 972
            aload 2 /* f */
            ifnull 3
         2: .line 973
            aload 2 /* f */
            aload 0 /* source */
            aload 1 /* observer */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.CompletableObserver
            areturn
         3: .line 975
      StackMap locals: io.reactivex.functions.BiFunction
      StackMap stack:
            aload 1 /* observer */
            areturn
        end local 2 // io.reactivex.functions.BiFunction f
        end local 1 // io.reactivex.CompletableObserver observer
        end local 0 // io.reactivex.Completable source
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0    source  Lio/reactivex/Completable;
            0    4     1  observer  Lio/reactivex/CompletableObserver;
            1    4     2         f  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Completable;-Lio/reactivex/CompletableObserver;+Lio/reactivex/CompletableObserver;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      source    
      observer  

  public static <T> io.reactivex.MaybeObserver<? super T> onSubscribe(io.reactivex.Maybe<T>, io.reactivex.MaybeObserver<? super T>);
    descriptor: (Lio/reactivex/Maybe;Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Maybe source
        start local 1 // io.reactivex.MaybeObserver observer
         0: .line 988
            getstatic io.reactivex.plugins.RxJavaPlugins.onMaybeSubscribe:Lio/reactivex/functions/BiFunction;
            astore 2 /* f */
        start local 2 // io.reactivex.functions.BiFunction f
         1: .line 989
            aload 2 /* f */
            ifnull 3
         2: .line 990
            aload 2 /* f */
            aload 0 /* source */
            aload 1 /* observer */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.MaybeObserver
            areturn
         3: .line 992
      StackMap locals: io.reactivex.functions.BiFunction
      StackMap stack:
            aload 1 /* observer */
            areturn
        end local 2 // io.reactivex.functions.BiFunction f
        end local 1 // io.reactivex.MaybeObserver observer
        end local 0 // io.reactivex.Maybe source
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0    source  Lio/reactivex/Maybe<TT;>;
            0    4     1  observer  Lio/reactivex/MaybeObserver<-TT;>;
            1    4     2         f  Lio/reactivex/functions/BiFunction<-Lio/reactivex/Maybe;-Lio/reactivex/MaybeObserver;+Lio/reactivex/MaybeObserver;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Maybe<TT;>;Lio/reactivex/MaybeObserver<-TT;>;)Lio/reactivex/MaybeObserver<-TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      source    
      observer  

  public static <T> io.reactivex.Maybe<T> onAssembly(io.reactivex.Maybe<T>);
    descriptor: (Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Maybe source
         0: .line 1004
            getstatic io.reactivex.plugins.RxJavaPlugins.onMaybeAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1005
            aload 1 /* f */
            ifnull 3
         2: .line 1006
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Maybe
            areturn
         3: .line 1008
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Maybe source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/Maybe<TT;>;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/Maybe;+Lio/reactivex/Maybe;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Maybe<TT;>;)Lio/reactivex/Maybe<TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static <T> io.reactivex.Flowable<T> onAssembly(io.reactivex.Flowable<T>);
    descriptor: (Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Flowable source
         0: .line 1020
            getstatic io.reactivex.plugins.RxJavaPlugins.onFlowableAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1021
            aload 1 /* f */
            ifnull 3
         2: .line 1022
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Flowable
            areturn
         3: .line 1024
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Flowable source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/Flowable<TT;>;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/Flowable;+Lio/reactivex/Flowable;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Flowable<TT;>;)Lio/reactivex/Flowable<TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static <T> io.reactivex.flowables.ConnectableFlowable<T> onAssembly(io.reactivex.flowables.ConnectableFlowable<T>);
    descriptor: (Lio/reactivex/flowables/ConnectableFlowable;)Lio/reactivex/flowables/ConnectableFlowable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.flowables.ConnectableFlowable source
         0: .line 1036
            getstatic io.reactivex.plugins.RxJavaPlugins.onConnectableFlowableAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1037
            aload 1 /* f */
            ifnull 3
         2: .line 1038
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.flowables.ConnectableFlowable
            areturn
         3: .line 1040
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.flowables.ConnectableFlowable source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/flowables/ConnectableFlowable<TT;>;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/flowables/ConnectableFlowable;+Lio/reactivex/flowables/ConnectableFlowable;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/flowables/ConnectableFlowable<TT;>;)Lio/reactivex/flowables/ConnectableFlowable<TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static <T> io.reactivex.Observable<T> onAssembly(io.reactivex.Observable<T>);
    descriptor: (Lio/reactivex/Observable;)Lio/reactivex/Observable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Observable source
         0: .line 1052
            getstatic io.reactivex.plugins.RxJavaPlugins.onObservableAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1053
            aload 1 /* f */
            ifnull 3
         2: .line 1054
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Observable
            areturn
         3: .line 1056
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Observable source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/Observable<TT;>;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/Observable;+Lio/reactivex/Observable;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Observable<TT;>;)Lio/reactivex/Observable<TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static <T> io.reactivex.observables.ConnectableObservable<T> onAssembly(io.reactivex.observables.ConnectableObservable<T>);
    descriptor: (Lio/reactivex/observables/ConnectableObservable;)Lio/reactivex/observables/ConnectableObservable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.observables.ConnectableObservable source
         0: .line 1068
            getstatic io.reactivex.plugins.RxJavaPlugins.onConnectableObservableAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1069
            aload 1 /* f */
            ifnull 3
         2: .line 1070
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.observables.ConnectableObservable
            areturn
         3: .line 1072
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.observables.ConnectableObservable source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/observables/ConnectableObservable<TT;>;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/observables/ConnectableObservable;+Lio/reactivex/observables/ConnectableObservable;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/observables/ConnectableObservable<TT;>;)Lio/reactivex/observables/ConnectableObservable<TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static <T> io.reactivex.Single<T> onAssembly(io.reactivex.Single<T>);
    descriptor: (Lio/reactivex/Single;)Lio/reactivex/Single;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Single source
         0: .line 1084
            getstatic io.reactivex.plugins.RxJavaPlugins.onSingleAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1085
            aload 1 /* f */
            ifnull 3
         2: .line 1086
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Single
            areturn
         3: .line 1088
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Single source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/Single<TT;>;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/Single;+Lio/reactivex/Single;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Single<TT;>;)Lio/reactivex/Single<TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static io.reactivex.Completable onAssembly(io.reactivex.Completable);
    descriptor: (Lio/reactivex/Completable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Completable source
         0: .line 1098
            getstatic io.reactivex.plugins.RxJavaPlugins.onCompletableAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1099
            aload 1 /* f */
            ifnull 3
         2: .line 1100
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Completable
            areturn
         3: .line 1102
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.Completable source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/Completable;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/Completable;+Lio/reactivex/Completable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static void setOnParallelAssembly(io.reactivex.functions.Function<? super io.reactivex.parallel.ParallelFlowable, ? extends io.reactivex.parallel.ParallelFlowable>);
    descriptor: (Lio/reactivex/functions/Function;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Function handler
         0: .line 1113
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 1114
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 1116
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onParallelAssembly:Lio/reactivex/functions/Function;
         3: .line 1117
            return
        end local 0 // io.reactivex.functions.Function handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable;+Lio/reactivex/parallel/ParallelFlowable;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable;+Lio/reactivex/parallel/ParallelFlowable;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static io.reactivex.functions.Function<? super io.reactivex.parallel.ParallelFlowable, ? extends io.reactivex.parallel.ParallelFlowable> getOnParallelAssembly();
    descriptor: ()Lio/reactivex/functions/Function;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 1128
            getstatic io.reactivex.plugins.RxJavaPlugins.onParallelAssembly:Lio/reactivex/functions/Function;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: ()Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable;+Lio/reactivex/parallel/ParallelFlowable;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static <T> io.reactivex.parallel.ParallelFlowable<T> onAssembly(io.reactivex.parallel.ParallelFlowable<T>);
    descriptor: (Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.parallel.ParallelFlowable source
         0: .line 1142
            getstatic io.reactivex.plugins.RxJavaPlugins.onParallelAssembly:Lio/reactivex/functions/Function;
            astore 1 /* f */
        start local 1 // io.reactivex.functions.Function f
         1: .line 1143
            aload 1 /* f */
            ifnull 3
         2: .line 1144
            aload 1 /* f */
            aload 0 /* source */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.parallel.ParallelFlowable
            areturn
         3: .line 1146
      StackMap locals: io.reactivex.functions.Function
      StackMap stack:
            aload 0 /* source */
            areturn
        end local 1 // io.reactivex.functions.Function f
        end local 0 // io.reactivex.parallel.ParallelFlowable source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            1    4     1       f  Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable;+Lio/reactivex/parallel/ParallelFlowable;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/parallel/ParallelFlowable<TT;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static boolean onBeforeBlocking();
    descriptor: ()Z
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=2, args_size=0
         0: .line 1160
            getstatic io.reactivex.plugins.RxJavaPlugins.onBeforeBlocking:Lio/reactivex/functions/BooleanSupplier;
            astore 0 /* f */
        start local 0 // io.reactivex.functions.BooleanSupplier f
         1: .line 1161
            aload 0 /* f */
            ifnull 6
         2: .line 1163
            aload 0 /* f */
            invokeinterface io.reactivex.functions.BooleanSupplier.getAsBoolean:()Z
         3: ireturn
         4: .line 1164
      StackMap locals: io.reactivex.functions.BooleanSupplier
      StackMap stack: java.lang.Throwable
            astore 1 /* ex */
        start local 1 // java.lang.Throwable ex
         5: .line 1165
            aload 1 /* ex */
            invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
            athrow
        end local 1 // java.lang.Throwable ex
         6: .line 1168
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 0 // io.reactivex.functions.BooleanSupplier f
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            1    7     0     f  Lio/reactivex/functions/BooleanSupplier;
            5    6     1    ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.Throwable

  public static void setOnBeforeBlocking(io.reactivex.functions.BooleanSupplier);
    descriptor: (Lio/reactivex/functions/BooleanSupplier;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.BooleanSupplier handler
         0: .line 1182
            getstatic io.reactivex.plugins.RxJavaPlugins.lockdown:Z
            ifeq 2
         1: .line 1183
            new java.lang.IllegalStateException
            dup
            ldc "Plugins can't be changed anymore"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 1185
      StackMap locals:
      StackMap stack:
            aload 0 /* handler */
            putstatic io.reactivex.plugins.RxJavaPlugins.onBeforeBlocking:Lio/reactivex/functions/BooleanSupplier;
         3: .line 1186
            return
        end local 0 // io.reactivex.functions.BooleanSupplier handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  handler  Lio/reactivex/functions/BooleanSupplier;
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      handler  

  public static io.reactivex.functions.BooleanSupplier getOnBeforeBlocking();
    descriptor: ()Lio/reactivex/functions/BooleanSupplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 1197
            getstatic io.reactivex.plugins.RxJavaPlugins.onBeforeBlocking:Lio/reactivex/functions/BooleanSupplier;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public static io.reactivex.Scheduler createComputationScheduler(java.util.concurrent.ThreadFactory);
    descriptor: (Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.util.concurrent.ThreadFactory threadFactory
         0: .line 1211
            new io.reactivex.internal.schedulers.ComputationScheduler
            dup
            aload 0 /* threadFactory */
            ldc "threadFactory is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast java.util.concurrent.ThreadFactory
            invokespecial io.reactivex.internal.schedulers.ComputationScheduler.<init>:(Ljava/util/concurrent/ThreadFactory;)V
            areturn
        end local 0 // java.util.concurrent.ThreadFactory threadFactory
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    1     0  threadFactory  Ljava/util/concurrent/ThreadFactory;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
               Name  Flags
      threadFactory  

  public static io.reactivex.Scheduler createIoScheduler(java.util.concurrent.ThreadFactory);
    descriptor: (Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.util.concurrent.ThreadFactory threadFactory
         0: .line 1225
            new io.reactivex.internal.schedulers.IoScheduler
            dup
            aload 0 /* threadFactory */
            ldc "threadFactory is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast java.util.concurrent.ThreadFactory
            invokespecial io.reactivex.internal.schedulers.IoScheduler.<init>:(Ljava/util/concurrent/ThreadFactory;)V
            areturn
        end local 0 // java.util.concurrent.ThreadFactory threadFactory
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    1     0  threadFactory  Ljava/util/concurrent/ThreadFactory;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
               Name  Flags
      threadFactory  

  public static io.reactivex.Scheduler createNewThreadScheduler(java.util.concurrent.ThreadFactory);
    descriptor: (Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.util.concurrent.ThreadFactory threadFactory
         0: .line 1239
            new io.reactivex.internal.schedulers.NewThreadScheduler
            dup
            aload 0 /* threadFactory */
            ldc "threadFactory is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast java.util.concurrent.ThreadFactory
            invokespecial io.reactivex.internal.schedulers.NewThreadScheduler.<init>:(Ljava/util/concurrent/ThreadFactory;)V
            areturn
        end local 0 // java.util.concurrent.ThreadFactory threadFactory
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    1     0  threadFactory  Ljava/util/concurrent/ThreadFactory;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
               Name  Flags
      threadFactory  

  public static io.reactivex.Scheduler createSingleScheduler(java.util.concurrent.ThreadFactory);
    descriptor: (Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.util.concurrent.ThreadFactory threadFactory
         0: .line 1253
            new io.reactivex.internal.schedulers.SingleScheduler
            dup
            aload 0 /* threadFactory */
            ldc "threadFactory is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast java.util.concurrent.ThreadFactory
            invokespecial io.reactivex.internal.schedulers.SingleScheduler.<init>:(Ljava/util/concurrent/ThreadFactory;)V
            areturn
        end local 0 // java.util.concurrent.ThreadFactory threadFactory
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    1     0  threadFactory  Ljava/util/concurrent/ThreadFactory;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
               Name  Flags
      threadFactory  

  static <T, R> R apply(io.reactivex.functions.Function<T, R>, );
    descriptor: (Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.reactivex.functions.Function f
        start local 1 // java.lang.Object t
         0: .line 1268
            aload 0 /* f */
            aload 1 /* t */
            invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
         1: areturn
         2: .line 1269
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* ex */
        start local 2 // java.lang.Throwable ex
         3: .line 1270
            aload 2 /* ex */
            invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
            athrow
        end local 2 // java.lang.Throwable ex
        end local 1 // java.lang.Object t
        end local 0 // io.reactivex.functions.Function f
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0     f  Lio/reactivex/functions/Function<TT;TR;>;
            0    4     1     t  TT;
            3    4     2    ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
    Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<TT;TR;>;TT;)TR;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      f     
      t     

  static <T, U, R> R apply(io.reactivex.functions.BiFunction<T, U, R>, T, );
    descriptor: (Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.reactivex.functions.BiFunction f
        start local 1 // java.lang.Object t
        start local 2 // java.lang.Object u
         0: .line 1288
            aload 0 /* f */
            aload 1 /* t */
            aload 2 /* u */
            invokeinterface io.reactivex.functions.BiFunction.apply:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
         1: areturn
         2: .line 1289
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 3 /* ex */
        start local 3 // java.lang.Throwable ex
         3: .line 1290
            aload 3 /* ex */
            invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
            athrow
        end local 3 // java.lang.Throwable ex
        end local 2 // java.lang.Object u
        end local 1 // java.lang.Object t
        end local 0 // io.reactivex.functions.BiFunction f
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0     f  Lio/reactivex/functions/BiFunction<TT;TU;TR;>;
            0    4     1     t  TT;
            0    4     2     u  TU;
            3    4     3    ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
    Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/BiFunction<TT;TU;TR;>;TT;TU;)TR;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
      2:
        io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      f     
      t     
      u     

  static io.reactivex.Scheduler callRequireNonNull(java.util.concurrent.Callable<io.reactivex.Scheduler>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.util.concurrent.Callable s
         0: .line 1304
            aload 0 /* s */
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
            ldc "Scheduler Callable result can't be null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
         1: areturn
         2: .line 1305
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 1 /* ex */
        start local 1 // java.lang.Throwable ex
         3: .line 1306
            aload 1 /* ex */
            invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
            athrow
        end local 1 // java.lang.Throwable ex
        end local 0 // java.util.concurrent.Callable s
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0     s  Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;
            3    4     1    ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
    Signature: (Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;)Lio/reactivex/Scheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      s     

  static io.reactivex.Scheduler applyRequireNonNull(io.reactivex.functions.Function<? super java.util.concurrent.Callable<io.reactivex.Scheduler>, ? extends io.reactivex.Scheduler>, java.util.concurrent.Callable<io.reactivex.Scheduler>);
    descriptor: (Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.functions.Function f
        start local 1 // java.util.concurrent.Callable s
         0: .line 1320
            aload 0 /* f */
            aload 1 /* s */
            invokestatic io.reactivex.plugins.RxJavaPlugins.apply:(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
            ldc "Scheduler Callable result can't be null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.Scheduler
            areturn
        end local 1 // java.util.concurrent.Callable s
        end local 0 // io.reactivex.functions.Function f
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     f  Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;
            0    1     1     s  Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;
    Signature: (Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;)Lio/reactivex/Scheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
      Name  Flags
      f     
      s     

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.plugins.RxJavaPlugins this
         0: .line 1324
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 1325
            new java.lang.IllegalStateException
            dup
            ldc "No instances!"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // io.reactivex.plugins.RxJavaPlugins this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/plugins/RxJavaPlugins;
}
SourceFile: "RxJavaPlugins.java"
InnerClasses:
  public abstract UncaughtExceptionHandler = java.lang.Thread$UncaughtExceptionHandler of java.lang.Thread