public abstract class io.reactivex.Completable implements io.reactivex.CompletableSource
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: io.reactivex.Completable
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 105
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;

  public static io.reactivex.Completable ambArray(io.reactivex.CompletableSource[]);
    descriptor: ([Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.reactivex.CompletableSource[] sources
         0: .line 124
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 125
            aload 0 /* sources */
            arraylength
            ifne 3
         2: .line 126
            invokestatic io.reactivex.Completable.complete:()Lio/reactivex/Completable;
            areturn
         3: .line 128
      StackMap locals:
      StackMap stack:
            aload 0 /* sources */
            arraylength
            iconst_1
            if_icmpne 5
         4: .line 129
            aload 0 /* sources */
            iconst_0
            aaload
            invokestatic io.reactivex.Completable.wrap:(Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
         5: .line 132
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.completable.CompletableAmb
            dup
            aload 0 /* sources */
            aconst_null
            invokespecial io.reactivex.internal.operators.completable.CompletableAmb.<init>:([Lio/reactivex/CompletableSource;Ljava/lang/Iterable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.CompletableSource[] sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0  sources  [Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  final

  public static io.reactivex.Completable amb(java.lang.Iterable<? extends io.reactivex.CompletableSource>);
    descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Iterable sources
         0: .line 153
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 155
            new io.reactivex.internal.operators.completable.CompletableAmb
            dup
            aconst_null
            aload 0 /* sources */
            invokespecial io.reactivex.internal.operators.completable.CompletableAmb.<init>:([Lio/reactivex/CompletableSource;Ljava/lang/Iterable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.lang.Iterable sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  sources  Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;
    Signature: (Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  final

  public static io.reactivex.Completable complete();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 172
            getstatic io.reactivex.internal.operators.completable.CompletableEmpty.INSTANCE:Lio/reactivex/Completable;
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()

  public static io.reactivex.Completable concatArray(io.reactivex.CompletableSource[]);
    descriptor: ([Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.CompletableSource[] sources
         0: .line 191
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 192
            aload 0 /* sources */
            arraylength
            ifne 3
         2: .line 193
            invokestatic io.reactivex.Completable.complete:()Lio/reactivex/Completable;
            areturn
         3: .line 195
      StackMap locals:
      StackMap stack:
            aload 0 /* sources */
            arraylength
            iconst_1
            if_icmpne 5
         4: .line 196
            aload 0 /* sources */
            iconst_0
            aaload
            invokestatic io.reactivex.Completable.wrap:(Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
         5: .line 198
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.completable.CompletableConcatArray
            dup
            aload 0 /* sources */
            invokespecial io.reactivex.internal.operators.completable.CompletableConcatArray.<init>:([Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.CompletableSource[] sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0  sources  [Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable concat(java.lang.Iterable<? extends io.reactivex.CompletableSource>);
    descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.lang.Iterable sources
         0: .line 217
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 219
            new io.reactivex.internal.operators.completable.CompletableConcatIterable
            dup
            aload 0 /* sources */
            invokespecial io.reactivex.internal.operators.completable.CompletableConcatIterable.<init>:(Ljava/lang/Iterable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.lang.Iterable sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  sources  Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;
    Signature: (Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable concat(org.reactivestreams.Publisher<? extends io.reactivex.CompletableSource>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher sources
         0: .line 241
            aload 0 /* sources */
            iconst_2
            invokestatic io.reactivex.Completable.concat:(Lorg/reactivestreams/Publisher;I)Lio/reactivex/Completable;
            areturn
        end local 0 // org.reactivestreams.Publisher sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  sources  Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;
    Signature: (Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable concat(org.reactivestreams.Publisher<? extends io.reactivex.CompletableSource>, int);
    descriptor: (Lorg/reactivestreams/Publisher;I)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.reactivestreams.Publisher sources
        start local 1 // int prefetch
         0: .line 265
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 266
            iload 1 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 267
            new io.reactivex.internal.operators.completable.CompletableConcat
            dup
            aload 0 /* sources */
            iload 1 /* prefetch */
            invokespecial io.reactivex.internal.operators.completable.CompletableConcat.<init>:(Lorg/reactivestreams/Publisher;I)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // int prefetch
        end local 0 // org.reactivestreams.Publisher sources
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0   sources  Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;
            0    3     1  prefetch  I
    Signature: (Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;I)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      sources   
      prefetch  

  public static io.reactivex.Completable create(io.reactivex.CompletableOnSubscribe);
    descriptor: (Lio/reactivex/CompletableOnSubscribe;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.CompletableOnSubscribe source
         0: .line 309
            aload 0 /* source */
            ldc "source is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 310
            new io.reactivex.internal.operators.completable.CompletableCreate
            dup
            aload 0 /* source */
            invokespecial io.reactivex.internal.operators.completable.CompletableCreate.<init>:(Lio/reactivex/CompletableOnSubscribe;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.CompletableOnSubscribe source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0  source  Lio/reactivex/CompletableOnSubscribe;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static io.reactivex.Completable unsafeCreate(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.CompletableSource source
         0: .line 332
            aload 0 /* source */
            ldc "source is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 333
            aload 0 /* source */
            instanceof io.reactivex.Completable
            ifeq 3
         2: .line 334
            new java.lang.IllegalArgumentException
            dup
            ldc "Use of unsafeCreate(Completable)!"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 336
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.completable.CompletableFromUnsafeSource
            dup
            aload 0 /* source */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromUnsafeSource.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.CompletableSource source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static io.reactivex.Completable defer(java.util.concurrent.Callable<? extends io.reactivex.CompletableSource>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.util.concurrent.Callable completableSupplier
         0: .line 354
            aload 0 /* completableSupplier */
            ldc "completableSupplier"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 355
            new io.reactivex.internal.operators.completable.CompletableDefer
            dup
            aload 0 /* completableSupplier */
            invokespecial io.reactivex.internal.operators.completable.CompletableDefer.<init>:(Ljava/util/concurrent/Callable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.util.concurrent.Callable completableSupplier
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    2     0  completableSupplier  Ljava/util/concurrent/Callable<+Lio/reactivex/CompletableSource;>;
    Signature: (Ljava/util/concurrent/Callable<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
                     Name  Flags
      completableSupplier  final

  public static io.reactivex.Completable error(java.util.concurrent.Callable<? extends java.lang.Throwable>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.util.concurrent.Callable errorSupplier
         0: .line 378
            aload 0 /* errorSupplier */
            ldc "errorSupplier is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 379
            new io.reactivex.internal.operators.completable.CompletableErrorSupplier
            dup
            aload 0 /* errorSupplier */
            invokespecial io.reactivex.internal.operators.completable.CompletableErrorSupplier.<init>:(Ljava/util/concurrent/Callable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.util.concurrent.Callable errorSupplier
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0  errorSupplier  Ljava/util/concurrent/Callable<+Ljava/lang/Throwable;>;
    Signature: (Ljava/util/concurrent/Callable<+Ljava/lang/Throwable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
               Name  Flags
      errorSupplier  final

  public static io.reactivex.Completable error(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.lang.Throwable error
         0: .line 398
            aload 0 /* error */
            ldc "error is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 399
            new io.reactivex.internal.operators.completable.CompletableError
            dup
            aload 0 /* error */
            invokespecial io.reactivex.internal.operators.completable.CompletableError.<init>:(Ljava/lang/Throwable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.lang.Throwable error
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0  error  Ljava/lang/Throwable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      error  final

  public static io.reactivex.Completable fromAction(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.functions.Action run
         0: .line 426
            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 427
            new io.reactivex.internal.operators.completable.CompletableFromAction
            dup
            aload 0 /* run */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromAction.<init>:(Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.functions.Action run
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   run  Lio/reactivex/functions/Action;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      run   final

  public static io.reactivex.Completable fromCallable(java.util.concurrent.Callable<?>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.util.concurrent.Callable callable
         0: .line 453
            aload 0 /* callable */
            ldc "callable is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 454
            new io.reactivex.internal.operators.completable.CompletableFromCallable
            dup
            aload 0 /* callable */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromCallable.<init>:(Ljava/util/concurrent/Callable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.util.concurrent.Callable callable
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0  callable  Ljava/util/concurrent/Callable<*>;
    Signature: (Ljava/util/concurrent/Callable<*>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      callable  final

  public static io.reactivex.Completable fromFuture(java.util.concurrent.Future<?>);
    descriptor: (Ljava/util/concurrent/Future;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.concurrent.Future future
         0: .line 474
            aload 0 /* future */
            ldc "future is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 475
            aload 0 /* future */
            invokestatic io.reactivex.internal.functions.Functions.futureAction:(Ljava/util/concurrent/Future;)Lio/reactivex/functions/Action;
            invokestatic io.reactivex.Completable.fromAction:(Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.util.concurrent.Future future
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0  future  Ljava/util/concurrent/Future<*>;
    Signature: (Ljava/util/concurrent/Future<*>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      future  final

  public static <T> io.reactivex.Completable fromMaybe(io.reactivex.MaybeSource<T>);
    descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.MaybeSource maybe
         0: .line 499
            aload 0 /* maybe */
            ldc "maybe is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 500
            new io.reactivex.internal.operators.maybe.MaybeIgnoreElementCompletable
            dup
            aload 0 /* maybe */
            invokespecial io.reactivex.internal.operators.maybe.MaybeIgnoreElementCompletable.<init>:(Lio/reactivex/MaybeSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.MaybeSource maybe
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0  maybe  Lio/reactivex/MaybeSource<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<TT;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      maybe  final

  public static io.reactivex.Completable fromRunnable(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.lang.Runnable run
         0: .line 527
            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 528
            new io.reactivex.internal.operators.completable.CompletableFromRunnable
            dup
            aload 0 /* run */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromRunnable.<init>:(Ljava/lang/Runnable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.lang.Runnable run
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   run  Ljava/lang/Runnable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      run   final

  public static <T> io.reactivex.Completable fromObservable(io.reactivex.ObservableSource<T>);
    descriptor: (Lio/reactivex/ObservableSource;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.ObservableSource observable
         0: .line 549
            aload 0 /* observable */
            ldc "observable is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 550
            new io.reactivex.internal.operators.completable.CompletableFromObservable
            dup
            aload 0 /* observable */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromObservable.<init>:(Lio/reactivex/ObservableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.ObservableSource observable
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0  observable  Lio/reactivex/ObservableSource<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/ObservableSource<TT;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      observable  final

  public static <T> io.reactivex.Completable fromPublisher(org.reactivestreams.Publisher<T>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher publisher
         0: .line 587
            aload 0 /* publisher */
            ldc "publisher is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 588
            new io.reactivex.internal.operators.completable.CompletableFromPublisher
            dup
            aload 0 /* publisher */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromPublisher.<init>:(Lorg/reactivestreams/Publisher;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // org.reactivestreams.Publisher publisher
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0  publisher  Lorg/reactivestreams/Publisher<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TT;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      publisher  final

  public static <T> io.reactivex.Completable fromSingle(io.reactivex.SingleSource<T>);
    descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.SingleSource single
         0: .line 609
            aload 0 /* single */
            ldc "single is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 610
            new io.reactivex.internal.operators.completable.CompletableFromSingle
            dup
            aload 0 /* single */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromSingle.<init>:(Lio/reactivex/SingleSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.SingleSource single
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0  single  Lio/reactivex/SingleSource<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<TT;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      single  final

  public static io.reactivex.Completable mergeArray(io.reactivex.CompletableSource[]);
    descriptor: ([Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.CompletableSource[] sources
         0: .line 644
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 645
            aload 0 /* sources */
            arraylength
            ifne 3
         2: .line 646
            invokestatic io.reactivex.Completable.complete:()Lio/reactivex/Completable;
            areturn
         3: .line 648
      StackMap locals:
      StackMap stack:
            aload 0 /* sources */
            arraylength
            iconst_1
            if_icmpne 5
         4: .line 649
            aload 0 /* sources */
            iconst_0
            aaload
            invokestatic io.reactivex.Completable.wrap:(Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
         5: .line 651
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.completable.CompletableMergeArray
            dup
            aload 0 /* sources */
            invokespecial io.reactivex.internal.operators.completable.CompletableMergeArray.<init>:([Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.CompletableSource[] sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0  sources  [Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable merge(java.lang.Iterable<? extends io.reactivex.CompletableSource>);
    descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.lang.Iterable sources
         0: .line 685
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 686
            new io.reactivex.internal.operators.completable.CompletableMergeIterable
            dup
            aload 0 /* sources */
            invokespecial io.reactivex.internal.operators.completable.CompletableMergeIterable.<init>:(Ljava/lang/Iterable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.lang.Iterable sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  sources  Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;
    Signature: (Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable merge(org.reactivestreams.Publisher<? extends io.reactivex.CompletableSource>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher sources
         0: .line 723
            aload 0 /* sources */
            ldc 2147483647
            iconst_0
            invokestatic io.reactivex.Completable.merge0:(Lorg/reactivestreams/Publisher;IZ)Lio/reactivex/Completable;
            areturn
        end local 0 // org.reactivestreams.Publisher sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  sources  Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;
    Signature: (Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind;)
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable merge(org.reactivestreams.Publisher<? extends io.reactivex.CompletableSource>, int);
    descriptor: (Lorg/reactivestreams/Publisher;I)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.reactivestreams.Publisher sources
        start local 1 // int maxConcurrency
         0: .line 762
            aload 0 /* sources */
            iload 1 /* maxConcurrency */
            iconst_0
            invokestatic io.reactivex.Completable.merge0:(Lorg/reactivestreams/Publisher;IZ)Lio/reactivex/Completable;
            areturn
        end local 1 // int maxConcurrency
        end local 0 // org.reactivestreams.Publisher sources
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    1     0         sources  Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;
            0    1     1  maxConcurrency  I
    Signature: (Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;I)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
    MethodParameters:
                Name  Flags
      sources         
      maxConcurrency  

  private static io.reactivex.Completable merge0(org.reactivestreams.Publisher<? extends io.reactivex.CompletableSource>, int, boolean);
    descriptor: (Lorg/reactivestreams/Publisher;IZ)Lio/reactivex/Completable;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // org.reactivestreams.Publisher sources
        start local 1 // int maxConcurrency
        start local 2 // boolean delayErrors
         0: .line 788
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 789
            iload 1 /* maxConcurrency */
            ldc "maxConcurrency"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 790
            new io.reactivex.internal.operators.completable.CompletableMerge
            dup
            aload 0 /* sources */
            iload 1 /* maxConcurrency */
            iload 2 /* delayErrors */
            invokespecial io.reactivex.internal.operators.completable.CompletableMerge.<init>:(Lorg/reactivestreams/Publisher;IZ)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 2 // boolean delayErrors
        end local 1 // int maxConcurrency
        end local 0 // org.reactivestreams.Publisher sources
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    3     0         sources  Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;
            0    3     1  maxConcurrency  I
            0    3     2     delayErrors  Z
    Signature: (Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;IZ)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
                Name  Flags
      sources         
      maxConcurrency  
      delayErrors     

  public static io.reactivex.Completable mergeArrayDelayError(io.reactivex.CompletableSource[]);
    descriptor: ([Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.CompletableSource[] sources
         0: .line 811
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 812
            new io.reactivex.internal.operators.completable.CompletableMergeDelayErrorArray
            dup
            aload 0 /* sources */
            invokespecial io.reactivex.internal.operators.completable.CompletableMergeDelayErrorArray.<init>:([Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.CompletableSource[] sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  sources  [Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable mergeDelayError(java.lang.Iterable<? extends io.reactivex.CompletableSource>);
    descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.lang.Iterable sources
         0: .line 833
            aload 0 /* sources */
            ldc "sources is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 834
            new io.reactivex.internal.operators.completable.CompletableMergeDelayErrorIterable
            dup
            aload 0 /* sources */
            invokespecial io.reactivex.internal.operators.completable.CompletableMergeDelayErrorIterable.<init>:(Ljava/lang/Iterable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // java.lang.Iterable sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  sources  Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;
    Signature: (Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable mergeDelayError(org.reactivestreams.Publisher<? extends io.reactivex.CompletableSource>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher sources
         0: .line 858
            aload 0 /* sources */
            ldc 2147483647
            iconst_1
            invokestatic io.reactivex.Completable.merge0:(Lorg/reactivestreams/Publisher;IZ)Lio/reactivex/Completable;
            areturn
        end local 0 // org.reactivestreams.Publisher sources
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  sources  Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;
    Signature: (Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind;)
    MethodParameters:
         Name  Flags
      sources  

  public static io.reactivex.Completable mergeDelayError(org.reactivestreams.Publisher<? extends io.reactivex.CompletableSource>, int);
    descriptor: (Lorg/reactivestreams/Publisher;I)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.reactivestreams.Publisher sources
        start local 1 // int maxConcurrency
         0: .line 884
            aload 0 /* sources */
            iload 1 /* maxConcurrency */
            iconst_1
            invokestatic io.reactivex.Completable.merge0:(Lorg/reactivestreams/Publisher;IZ)Lio/reactivex/Completable;
            areturn
        end local 1 // int maxConcurrency
        end local 0 // org.reactivestreams.Publisher sources
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    1     0         sources  Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;
            0    1     1  maxConcurrency  I
    Signature: (Lorg/reactivestreams/Publisher<+Lio/reactivex/CompletableSource;>;I)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
    MethodParameters:
                Name  Flags
      sources         
      maxConcurrency  

  public static io.reactivex.Completable never();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 900
            getstatic io.reactivex.internal.operators.completable.CompletableNever.INSTANCE:Lio/reactivex/Completable;
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public static io.reactivex.Completable timer(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // long delay
        start local 2 // java.util.concurrent.TimeUnit unit
         0: .line 918
            lload 0 /* delay */
            aload 2 /* unit */
            invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
            invokestatic io.reactivex.Completable.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
            areturn
        end local 2 // java.util.concurrent.TimeUnit unit
        end local 0 // long delay
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  delay  J
            0    1     2   unit  Ljava/util/concurrent/TimeUnit;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
    MethodParameters:
       Name  Flags
      delay  
      unit   

  public static io.reactivex.Completable timer(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=4, args_size=3
        start local 0 // long delay
        start local 2 // java.util.concurrent.TimeUnit unit
        start local 3 // io.reactivex.Scheduler scheduler
         0: .line 939
            aload 2 /* unit */
            ldc "unit is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 940
            aload 3 /* scheduler */
            ldc "scheduler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 941
            new io.reactivex.internal.operators.completable.CompletableTimer
            dup
            lload 0 /* delay */
            aload 2 /* unit */
            aload 3 /* scheduler */
            invokespecial io.reactivex.internal.operators.completable.CompletableTimer.<init>:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 3 // io.reactivex.Scheduler scheduler
        end local 2 // java.util.concurrent.TimeUnit unit
        end local 0 // long delay
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0      delay  J
            0    3     2       unit  Ljava/util/concurrent/TimeUnit;
            0    3     3  scheduler  Lio/reactivex/Scheduler;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      delay      final
      unit       final
      scheduler  final

  private static java.lang.NullPointerException toNpe(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Ljava/lang/NullPointerException;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // java.lang.Throwable ex
         0: .line 950
            new java.lang.NullPointerException
            dup
            ldc "Actually not, but can't pass out an exception otherwise..."
            invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
            astore 1 /* npe */
        start local 1 // java.lang.NullPointerException npe
         1: .line 951
            aload 1 /* npe */
            aload 0 /* ex */
            invokevirtual java.lang.NullPointerException.initCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
            pop
         2: .line 952
            aload 1 /* npe */
            areturn
        end local 1 // java.lang.NullPointerException npe
        end local 0 // java.lang.Throwable ex
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0    ex  Ljava/lang/Throwable;
            1    3     1   npe  Ljava/lang/NullPointerException;
    MethodParameters:
      Name  Flags
      ex    

  public static <R> io.reactivex.Completable using(java.util.concurrent.Callable<R>, io.reactivex.functions.Function<? super R, ? extends io.reactivex.CompletableSource>, io.reactivex.functions.Consumer<? super R>);
    descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // java.util.concurrent.Callable resourceSupplier
        start local 1 // io.reactivex.functions.Function completableFunction
        start local 2 // io.reactivex.functions.Consumer disposer
         0: .line 977
            aload 0 /* resourceSupplier */
            aload 1 /* completableFunction */
            aload 2 /* disposer */
            iconst_1
            invokestatic io.reactivex.Completable.using:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Completable;
            areturn
        end local 2 // io.reactivex.functions.Consumer disposer
        end local 1 // io.reactivex.functions.Function completableFunction
        end local 0 // java.util.concurrent.Callable resourceSupplier
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    1     0     resourceSupplier  Ljava/util/concurrent/Callable<TR;>;
            0    1     1  completableFunction  Lio/reactivex/functions/Function<-TR;+Lio/reactivex/CompletableSource;>;
            0    1     2             disposer  Lio/reactivex/functions/Consumer<-TR;>;
    Signature: <R:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<TR;>;Lio/reactivex/functions/Function<-TR;+Lio/reactivex/CompletableSource;>;Lio/reactivex/functions/Consumer<-TR;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
                     Name  Flags
      resourceSupplier     
      completableFunction  
      disposer             

  public static <R> io.reactivex.Completable using(java.util.concurrent.Callable<R>, io.reactivex.functions.Function<? super R, ? extends io.reactivex.CompletableSource>, io.reactivex.functions.Consumer<? super R>, boolean);
    descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=4, args_size=4
        start local 0 // java.util.concurrent.Callable resourceSupplier
        start local 1 // io.reactivex.functions.Function completableFunction
        start local 2 // io.reactivex.functions.Consumer disposer
        start local 3 // boolean eager
         0: .line 1010
            aload 0 /* resourceSupplier */
            ldc "resourceSupplier is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1011
            aload 1 /* completableFunction */
            ldc "completableFunction is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 1012
            aload 2 /* disposer */
            ldc "disposer is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         3: .line 1014
            new io.reactivex.internal.operators.completable.CompletableUsing
            dup
            aload 0 /* resourceSupplier */
            aload 1 /* completableFunction */
            aload 2 /* disposer */
            iload 3 /* eager */
            invokespecial io.reactivex.internal.operators.completable.CompletableUsing.<init>:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 3 // boolean eager
        end local 2 // io.reactivex.functions.Consumer disposer
        end local 1 // io.reactivex.functions.Function completableFunction
        end local 0 // java.util.concurrent.Callable resourceSupplier
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    4     0     resourceSupplier  Ljava/util/concurrent/Callable<TR;>;
            0    4     1  completableFunction  Lio/reactivex/functions/Function<-TR;+Lio/reactivex/CompletableSource;>;
            0    4     2             disposer  Lio/reactivex/functions/Consumer<-TR;>;
            0    4     3                eager  Z
    Signature: <R:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<TR;>;Lio/reactivex/functions/Function<-TR;+Lio/reactivex/CompletableSource;>;Lio/reactivex/functions/Consumer<-TR;>;Z)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
                     Name  Flags
      resourceSupplier     final
      completableFunction  final
      disposer             final
      eager                final

  public static io.reactivex.Completable wrap(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.CompletableSource source
         0: .line 1034
            aload 0 /* source */
            ldc "source is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1035
            aload 0 /* source */
            instanceof io.reactivex.Completable
            ifeq 3
         2: .line 1036
            aload 0 /* source */
            checkcast io.reactivex.Completable
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
         3: .line 1038
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.completable.CompletableFromUnsafeSource
            dup
            aload 0 /* source */
            invokespecial io.reactivex.internal.operators.completable.CompletableFromUnsafeSource.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.CompletableSource source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  source  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public final io.reactivex.Completable ambWith(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableSource other
         0: .line 1059
            aload 1 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1060
            iconst_2
            anewarray io.reactivex.CompletableSource
            dup
            iconst_0
            aload 0 /* this */
            aastore
            dup
            iconst_1
            aload 1 /* other */
            aastore
            invokestatic io.reactivex.Completable.ambArray:([Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableSource other
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/Completable;
            0    2     1  other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      other  

  public final <T> io.reactivex.Observable<T> andThen(io.reactivex.ObservableSource<T>);
    descriptor: (Lio/reactivex/ObservableSource;)Lio/reactivex/Observable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.ObservableSource next
         0: .line 1083
            aload 1 /* next */
            ldc "next is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1084
            new io.reactivex.internal.operators.mixed.CompletableAndThenObservable
            dup
            aload 0 /* this */
            aload 1 /* next */
            invokespecial io.reactivex.internal.operators.mixed.CompletableAndThenObservable.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/ObservableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Observable;)Lio/reactivex/Observable;
            areturn
        end local 1 // io.reactivex.ObservableSource next
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/Completable;
            0    2     1  next  Lio/reactivex/ObservableSource<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/ObservableSource<TT;>;)Lio/reactivex/Observable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      next  

  public final <T> io.reactivex.Flowable<T> andThen(org.reactivestreams.Publisher<T>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // org.reactivestreams.Publisher next
         0: .line 1111
            aload 1 /* next */
            ldc "next is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1112
            new io.reactivex.internal.operators.mixed.CompletableAndThenPublisher
            dup
            aload 0 /* this */
            aload 1 /* next */
            invokespecial io.reactivex.internal.operators.mixed.CompletableAndThenPublisher.<init>:(Lio/reactivex/CompletableSource;Lorg/reactivestreams/Publisher;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
            areturn
        end local 1 // org.reactivestreams.Publisher next
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/Completable;
            0    2     1  next  Lorg/reactivestreams/Publisher<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TT;>;)Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      next  

  public final <T> io.reactivex.Single<T> andThen(io.reactivex.SingleSource<T>);
    descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Single;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.SingleSource next
         0: .line 1135
            aload 1 /* next */
            ldc "next is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1136
            new io.reactivex.internal.operators.single.SingleDelayWithCompletable
            dup
            aload 1 /* next */
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.single.SingleDelayWithCompletable.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
            areturn
        end local 1 // io.reactivex.SingleSource next
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/Completable;
            0    2     1  next  Lio/reactivex/SingleSource<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<TT;>;)Lio/reactivex/Single<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      next  

  public final <T> io.reactivex.Maybe<T> andThen(io.reactivex.MaybeSource<T>);
    descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.MaybeSource next
         0: .line 1159
            aload 1 /* next */
            ldc "next is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1160
            new io.reactivex.internal.operators.maybe.MaybeDelayWithCompletable
            dup
            aload 1 /* next */
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.maybe.MaybeDelayWithCompletable.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
            areturn
        end local 1 // io.reactivex.MaybeSource next
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/Completable;
            0    2     1  next  Lio/reactivex/MaybeSource<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<TT;>;)Lio/reactivex/Maybe<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      next  

  public final io.reactivex.Completable andThen(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableSource next
         0: .line 1181
            aload 1 /* next */
            ldc "next is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1182
            new io.reactivex.internal.operators.completable.CompletableAndThenCompletable
            dup
            aload 0 /* this */
            aload 1 /* next */
            invokespecial io.reactivex.internal.operators.completable.CompletableAndThenCompletable.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableSource next
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/Completable;
            0    2     1  next  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
      Name  Flags
      next  

  public final <R> R as(io.reactivex.CompletableConverter<? extends R>);
    descriptor: (Lio/reactivex/CompletableConverter;)Ljava/lang/Object;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableConverter converter
         0: .line 1205
            aload 1 /* converter */
            ldc "converter is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.CompletableConverter
            aload 0 /* this */
            invokeinterface io.reactivex.CompletableConverter.apply:(Lio/reactivex/Completable;)Ljava/lang/Object;
            areturn
        end local 1 // io.reactivex.CompletableConverter converter
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/Completable;
            0    1     1  converter  Lio/reactivex/CompletableConverter<+TR;>;
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/CompletableConverter<+TR;>;)TR;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      converter  

  public final void blockingAwait();
    descriptor: ()V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 1225
            new io.reactivex.internal.observers.BlockingMultiObserver
            dup
            invokespecial io.reactivex.internal.observers.BlockingMultiObserver.<init>:()V
            astore 1 /* observer */
        start local 1 // io.reactivex.internal.observers.BlockingMultiObserver observer
         1: .line 1226
            aload 0 /* this */
            aload 1 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         2: .line 1227
            aload 1 /* observer */
            invokevirtual io.reactivex.internal.observers.BlockingMultiObserver.blockingGet:()Ljava/lang/Object;
            pop
         3: .line 1228
            return
        end local 1 // io.reactivex.internal.observers.BlockingMultiObserver observer
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/reactivex/Completable;
            1    4     1  observer  Lio/reactivex/internal/observers/BlockingMultiObserver<Ljava/lang/Void;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final boolean blockingAwait(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)Z
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // io.reactivex.Completable this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
         0: .line 1253
            aload 3 /* unit */
            ldc "unit is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1254
            new io.reactivex.internal.observers.BlockingMultiObserver
            dup
            invokespecial io.reactivex.internal.observers.BlockingMultiObserver.<init>:()V
            astore 4 /* observer */
        start local 4 // io.reactivex.internal.observers.BlockingMultiObserver observer
         2: .line 1255
            aload 0 /* this */
            aload 4 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         3: .line 1256
            aload 4 /* observer */
            lload 1 /* timeout */
            aload 3 /* unit */
            invokevirtual io.reactivex.internal.observers.BlockingMultiObserver.blockingAwait:(JLjava/util/concurrent/TimeUnit;)Z
            ireturn
        end local 4 // io.reactivex.internal.observers.BlockingMultiObserver observer
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/reactivex/Completable;
            0    4     1   timeout  J
            0    4     3      unit  Ljava/util/concurrent/TimeUnit;
            2    4     4  observer  Lio/reactivex/internal/observers/BlockingMultiObserver<Ljava/lang/Void;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      timeout  
      unit     

  public final java.lang.Throwable blockingGet();
    descriptor: ()Ljava/lang/Throwable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 1275
            new io.reactivex.internal.observers.BlockingMultiObserver
            dup
            invokespecial io.reactivex.internal.observers.BlockingMultiObserver.<init>:()V
            astore 1 /* observer */
        start local 1 // io.reactivex.internal.observers.BlockingMultiObserver observer
         1: .line 1276
            aload 0 /* this */
            aload 1 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         2: .line 1277
            aload 1 /* observer */
            invokevirtual io.reactivex.internal.observers.BlockingMultiObserver.blockingGetError:()Ljava/lang/Throwable;
            areturn
        end local 1 // io.reactivex.internal.observers.BlockingMultiObserver observer
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lio/reactivex/Completable;
            1    3     1  observer  Lio/reactivex/internal/observers/BlockingMultiObserver<Ljava/lang/Void;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()

  public final java.lang.Throwable blockingGet(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)Ljava/lang/Throwable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // io.reactivex.Completable this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
         0: .line 1299
            aload 3 /* unit */
            ldc "unit is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1300
            new io.reactivex.internal.observers.BlockingMultiObserver
            dup
            invokespecial io.reactivex.internal.observers.BlockingMultiObserver.<init>:()V
            astore 4 /* observer */
        start local 4 // io.reactivex.internal.observers.BlockingMultiObserver observer
         2: .line 1301
            aload 0 /* this */
            aload 4 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         3: .line 1302
            aload 4 /* observer */
            lload 1 /* timeout */
            aload 3 /* unit */
            invokevirtual io.reactivex.internal.observers.BlockingMultiObserver.blockingGetError:(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Throwable;
            areturn
        end local 4 // io.reactivex.internal.observers.BlockingMultiObserver observer
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/reactivex/Completable;
            0    4     1   timeout  J
            0    4     3      unit  Ljava/util/concurrent/TimeUnit;
            2    4     4  observer  Lio/reactivex/internal/observers/BlockingMultiObserver<Ljava/lang/Void;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()
    MethodParameters:
         Name  Flags
      timeout  
      unit     

  public final io.reactivex.Completable cache();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 1325
            new io.reactivex.internal.operators.completable.CompletableCache
            dup
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.completable.CompletableCache.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final io.reactivex.Completable compose(io.reactivex.CompletableTransformer);
    descriptor: (Lio/reactivex/CompletableTransformer;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableTransformer transformer
         0: .line 1344
            aload 1 /* transformer */
            ldc "transformer is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.CompletableTransformer
            aload 0 /* this */
            invokeinterface io.reactivex.CompletableTransformer.apply:(Lio/reactivex/Completable;)Lio/reactivex/CompletableSource;
            invokestatic io.reactivex.Completable.wrap:(Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableTransformer transformer
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    1     0         this  Lio/reactivex/Completable;
            0    1     1  transformer  Lio/reactivex/CompletableTransformer;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
             Name  Flags
      transformer  

  public final io.reactivex.Completable concatWith(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableSource other
         0: .line 1367
            aload 1 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1368
            new io.reactivex.internal.operators.completable.CompletableAndThenCompletable
            dup
            aload 0 /* this */
            aload 1 /* other */
            invokespecial io.reactivex.internal.operators.completable.CompletableAndThenCompletable.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableSource other
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/Completable;
            0    2     1  other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      other  

  public final io.reactivex.Completable delay(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=4, args_size=3
        start local 0 // io.reactivex.Completable this
        start local 1 // long delay
        start local 3 // java.util.concurrent.TimeUnit unit
         0: .line 1387
            aload 0 /* this */
            lload 1 /* delay */
            aload 3 /* unit */
            invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
            iconst_0
            invokevirtual io.reactivex.Completable.delay:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Completable;
            areturn
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long delay
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/reactivex/Completable;
            0    1     1  delay  J
            0    1     3   unit  Ljava/util/concurrent/TimeUnit;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
    MethodParameters:
       Name  Flags
      delay  
      unit   

  public final io.reactivex.Completable delay(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // io.reactivex.Completable this
        start local 1 // long delay
        start local 3 // java.util.concurrent.TimeUnit unit
        start local 4 // io.reactivex.Scheduler scheduler
         0: .line 1408
            aload 0 /* this */
            lload 1 /* delay */
            aload 3 /* unit */
            aload 4 /* scheduler */
            iconst_0
            invokevirtual io.reactivex.Completable.delay:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Completable;
            areturn
        end local 4 // io.reactivex.Scheduler scheduler
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long delay
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/Completable;
            0    1     1      delay  J
            0    1     3       unit  Ljava/util/concurrent/TimeUnit;
            0    1     4  scheduler  Lio/reactivex/Scheduler;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    MethodParameters:
           Name  Flags
      delay      
      unit       
      scheduler  

  public final io.reactivex.Completable delay(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, boolean);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=8, locals=6, args_size=5
        start local 0 // io.reactivex.Completable this
        start local 1 // long delay
        start local 3 // java.util.concurrent.TimeUnit unit
        start local 4 // io.reactivex.Scheduler scheduler
        start local 5 // boolean delayError
         0: .line 1431
            aload 3 /* unit */
            ldc "unit is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1432
            aload 4 /* scheduler */
            ldc "scheduler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 1433
            new io.reactivex.internal.operators.completable.CompletableDelay
            dup
            aload 0 /* this */
            lload 1 /* delay */
            aload 3 /* unit */
            aload 4 /* scheduler */
            iload 5 /* delayError */
            invokespecial io.reactivex.internal.operators.completable.CompletableDelay.<init>:(Lio/reactivex/CompletableSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 5 // boolean delayError
        end local 4 // io.reactivex.Scheduler scheduler
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long delay
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lio/reactivex/Completable;
            0    3     1       delay  J
            0    3     3        unit  Ljava/util/concurrent/TimeUnit;
            0    3     4   scheduler  Lio/reactivex/Scheduler;
            0    3     5  delayError  Z
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      delay       final
      unit        final
      scheduler   final
      delayError  final

  public final io.reactivex.Completable delaySubscription(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.reactivex.Completable this
        start local 1 // long delay
        start local 3 // java.util.concurrent.TimeUnit unit
         0: .line 1455
            aload 0 /* this */
            lload 1 /* delay */
            aload 3 /* unit */
            invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
            invokevirtual io.reactivex.Completable.delaySubscription:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
            areturn
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long delay
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/reactivex/Completable;
            0    1     1  delay  J
            0    1     3   unit  Ljava/util/concurrent/TimeUnit;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Experimental()
    RuntimeInvisibleTypeAnnotations: 
      METHOD_RETURN
        io.reactivex.annotations.Experimental()
    MethodParameters:
       Name  Flags
      delay  
      unit   

  public final io.reactivex.Completable delaySubscription(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=5, args_size=4
        start local 0 // io.reactivex.Completable this
        start local 1 // long delay
        start local 3 // java.util.concurrent.TimeUnit unit
        start local 4 // io.reactivex.Scheduler scheduler
         0: .line 1480
            lload 1 /* delay */
            aload 3 /* unit */
            aload 4 /* scheduler */
            invokestatic io.reactivex.Completable.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.andThen:(Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 4 // io.reactivex.Scheduler scheduler
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long delay
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/Completable;
            0    1     1      delay  J
            0    1     3       unit  Ljava/util/concurrent/TimeUnit;
            0    1     4  scheduler  Lio/reactivex/Scheduler;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Experimental()
    RuntimeInvisibleTypeAnnotations: 
      METHOD_RETURN
        io.reactivex.annotations.Experimental()
    MethodParameters:
           Name  Flags
      delay      
      unit       
      scheduler  

  public final io.reactivex.Completable doOnComplete(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=7, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Action onComplete
         0: .line 1499
            aload 0 /* this */
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         1: .line 1500
            aload 1 /* onComplete */
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         2: .line 1501
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         3: .line 1499
            invokevirtual io.reactivex.Completable.doOnLifecycle:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Action onComplete
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lio/reactivex/Completable;
            0    4     1  onComplete  Lio/reactivex/functions/Action;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
            Name  Flags
      onComplete  

  public final io.reactivex.Completable doOnDispose(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=7, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Action onDispose
         0: .line 1520
            aload 0 /* this */
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         1: .line 1521
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         2: .line 1522
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            aload 1 /* onDispose */
         3: .line 1520
            invokevirtual io.reactivex.Completable.doOnLifecycle:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Action onDispose
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0       this  Lio/reactivex/Completable;
            0    4     1  onDispose  Lio/reactivex/functions/Action;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
           Name  Flags
      onDispose  

  public final io.reactivex.Completable doOnError(io.reactivex.functions.Consumer<? super java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=7, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Consumer onError
         0: .line 1541
            aload 0 /* this */
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
            aload 1 /* onError */
         1: .line 1542
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         2: .line 1543
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         3: .line 1541
            invokevirtual io.reactivex.Completable.doOnLifecycle:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Consumer onError
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/reactivex/Completable;
            0    4     1  onError  Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
    Signature: (Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
         Name  Flags
      onError  

  public final io.reactivex.Completable doOnEvent(io.reactivex.functions.Consumer<? super java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Consumer onEvent
         0: .line 1563
            aload 1 /* onEvent */
            ldc "onEvent is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1564
            new io.reactivex.internal.operators.completable.CompletableDoOnEvent
            dup
            aload 0 /* this */
            aload 1 /* onEvent */
            invokespecial io.reactivex.internal.operators.completable.CompletableDoOnEvent.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/functions/Consumer;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Consumer onEvent
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/reactivex/Completable;
            0    2     1  onEvent  Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
    Signature: (Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      onEvent  final

  private io.reactivex.Completable doOnLifecycle(io.reactivex.functions.Consumer<? super io.reactivex.disposables.Disposable>, io.reactivex.functions.Consumer<? super java.lang.Throwable>, io.reactivex.functions.Action, io.reactivex.functions.Action, io.reactivex.functions.Action, io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=9, locals=7, args_size=7
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Consumer onSubscribe
        start local 2 // io.reactivex.functions.Consumer onError
        start local 3 // io.reactivex.functions.Action onComplete
        start local 4 // io.reactivex.functions.Action onTerminate
        start local 5 // io.reactivex.functions.Action onAfterTerminate
        start local 6 // io.reactivex.functions.Action onDispose
         0: .line 1591
            aload 1 /* onSubscribe */
            ldc "onSubscribe is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1592
            aload 2 /* onError */
            ldc "onError is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 1593
            aload 3 /* onComplete */
            ldc "onComplete is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         3: .line 1594
            aload 4 /* onTerminate */
            ldc "onTerminate is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         4: .line 1595
            aload 5 /* onAfterTerminate */
            ldc "onAfterTerminate is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         5: .line 1596
            aload 6 /* onDispose */
            ldc "onDispose is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         6: .line 1597
            new io.reactivex.internal.operators.completable.CompletablePeek
            dup
            aload 0 /* this */
            aload 1 /* onSubscribe */
            aload 2 /* onError */
            aload 3 /* onComplete */
            aload 4 /* onTerminate */
            aload 5 /* onAfterTerminate */
            aload 6 /* onDispose */
            invokespecial io.reactivex.internal.operators.completable.CompletablePeek.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 6 // io.reactivex.functions.Action onDispose
        end local 5 // io.reactivex.functions.Action onAfterTerminate
        end local 4 // io.reactivex.functions.Action onTerminate
        end local 3 // io.reactivex.functions.Action onComplete
        end local 2 // io.reactivex.functions.Consumer onError
        end local 1 // io.reactivex.functions.Consumer onSubscribe
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lio/reactivex/Completable;
            0    7     1       onSubscribe  Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;
            0    7     2           onError  Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
            0    7     3        onComplete  Lio/reactivex/functions/Action;
            0    7     4       onTerminate  Lio/reactivex/functions/Action;
            0    7     5  onAfterTerminate  Lio/reactivex/functions/Action;
            0    7     6         onDispose  Lio/reactivex/functions/Action;
    Signature: (Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      onSubscribe       final
      onError           final
      onComplete        final
      onTerminate       final
      onAfterTerminate  final
      onDispose         final

  public final io.reactivex.Completable doOnSubscribe(io.reactivex.functions.Consumer<? super io.reactivex.disposables.Disposable>);
    descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=7, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Consumer onSubscribe
         0: .line 1616
            aload 0 /* this */
            aload 1 /* onSubscribe */
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         1: .line 1617
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         2: .line 1618
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         3: .line 1616
            invokevirtual io.reactivex.Completable.doOnLifecycle:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Consumer onSubscribe
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lio/reactivex/Completable;
            0    4     1  onSubscribe  Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;
    Signature: (Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
             Name  Flags
      onSubscribe  

  public final io.reactivex.Completable doOnTerminate(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=7, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Action onTerminate
         0: .line 1637
            aload 0 /* this */
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         1: .line 1638
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            aload 1 /* onTerminate */
         2: .line 1639
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         3: .line 1637
            invokevirtual io.reactivex.Completable.doOnLifecycle:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Action onTerminate
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lio/reactivex/Completable;
            0    4     1  onTerminate  Lio/reactivex/functions/Action;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
             Name  Flags
      onTerminate  final

  public final io.reactivex.Completable doAfterTerminate(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=7, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Action onAfterTerminate
         0: .line 1658
            aload 0 /* this */
         1: .line 1659
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         2: .line 1660
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 1661
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         4: .line 1662
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         5: .line 1663
            aload 1 /* onAfterTerminate */
         6: .line 1664
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 1658
            invokevirtual io.reactivex.Completable.doOnLifecycle:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Action onAfterTerminate
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    8     0              this  Lio/reactivex/Completable;
            0    8     1  onAfterTerminate  Lio/reactivex/functions/Action;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
                  Name  Flags
      onAfterTerminate  final

  public final io.reactivex.Completable doFinally(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Action onFinally
         0: .line 1690
            aload 1 /* onFinally */
            ldc "onFinally is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1691
            new io.reactivex.internal.operators.completable.CompletableDoFinally
            dup
            aload 0 /* this */
            aload 1 /* onFinally */
            invokespecial io.reactivex.internal.operators.completable.CompletableDoFinally.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Action onFinally
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/reactivex/Completable;
            0    2     1  onFinally  Lio/reactivex/functions/Action;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      onFinally  

  public final io.reactivex.Completable lift(io.reactivex.CompletableOperator);
    descriptor: (Lio/reactivex/CompletableOperator;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableOperator onLift
         0: .line 1828
            aload 1 /* onLift */
            ldc "onLift is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1829
            new io.reactivex.internal.operators.completable.CompletableLift
            dup
            aload 0 /* this */
            aload 1 /* onLift */
            invokespecial io.reactivex.internal.operators.completable.CompletableLift.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/CompletableOperator;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableOperator onLift
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lio/reactivex/Completable;
            0    2     1  onLift  Lio/reactivex/CompletableOperator;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      onLift  final

  public final <T> io.reactivex.Single<io.reactivex.Notification<T>> materialize();
    descriptor: ()Lio/reactivex/Single;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 1850
            new io.reactivex.internal.operators.completable.CompletableMaterialize
            dup
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.completable.CompletableMaterialize.<init>:(Lio/reactivex/Completable;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
    Signature: <T:Ljava/lang/Object;>()Lio/reactivex/Single<Lio/reactivex/Notification<TT;>;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Experimental()
    RuntimeInvisibleTypeAnnotations: 
      METHOD_RETURN
        io.reactivex.annotations.Experimental()

  public final io.reactivex.Completable mergeWith(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableSource other
         0: .line 1870
            aload 1 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1871
            iconst_2
            anewarray io.reactivex.CompletableSource
            dup
            iconst_0
            aload 0 /* this */
            aastore
            dup
            iconst_1
            aload 1 /* other */
            aastore
            invokestatic io.reactivex.Completable.mergeArray:([Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableSource other
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/Completable;
            0    2     1  other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      other  

  public final io.reactivex.Completable observeOn(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.Scheduler scheduler
         0: .line 1890
            aload 1 /* scheduler */
            ldc "scheduler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1891
            new io.reactivex.internal.operators.completable.CompletableObserveOn
            dup
            aload 0 /* this */
            aload 1 /* scheduler */
            invokespecial io.reactivex.internal.operators.completable.CompletableObserveOn.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/Scheduler;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.Scheduler scheduler
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/reactivex/Completable;
            0    2     1  scheduler  Lio/reactivex/Scheduler;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      scheduler  final

  public final io.reactivex.Completable onErrorComplete();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 1908
            aload 0 /* this */
            invokestatic io.reactivex.internal.functions.Functions.alwaysTrue:()Lio/reactivex/functions/Predicate;
            invokevirtual io.reactivex.Completable.onErrorComplete:(Lio/reactivex/functions/Predicate;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final io.reactivex.Completable onErrorComplete(io.reactivex.functions.Predicate<? super java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/Predicate;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Predicate predicate
         0: .line 1928
            aload 1 /* predicate */
            ldc "predicate is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1930
            new io.reactivex.internal.operators.completable.CompletableOnErrorComplete
            dup
            aload 0 /* this */
            aload 1 /* predicate */
            invokespecial io.reactivex.internal.operators.completable.CompletableOnErrorComplete.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/functions/Predicate;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Predicate predicate
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/reactivex/Completable;
            0    2     1  predicate  Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;
    Signature: (Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      predicate  final

  public final io.reactivex.Completable onErrorResumeNext(io.reactivex.functions.Function<? super java.lang.Throwable, ? extends io.reactivex.CompletableSource>);
    descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Function errorMapper
         0: .line 1951
            aload 1 /* errorMapper */
            ldc "errorMapper is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 1952
            new io.reactivex.internal.operators.completable.CompletableResumeNext
            dup
            aload 0 /* this */
            aload 1 /* errorMapper */
            invokespecial io.reactivex.internal.operators.completable.CompletableResumeNext.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/functions/Function;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Function errorMapper
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lio/reactivex/Completable;
            0    2     1  errorMapper  Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/CompletableSource;>;
    Signature: (Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
             Name  Flags
      errorMapper  final

  public final io.reactivex.Completable onTerminateDetach();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 1972
            new io.reactivex.internal.operators.completable.CompletableDetach
            dup
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.completable.CompletableDetach.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final io.reactivex.Completable repeat();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 1988
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            invokevirtual io.reactivex.Flowable.repeat:()Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final io.reactivex.Completable repeat(long);
    descriptor: (J)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // long times
         0: .line 2006
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            lload 1 /* times */
            invokevirtual io.reactivex.Flowable.repeat:(J)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 1 // long times
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/reactivex/Completable;
            0    1     1  times  J
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
       Name  Flags
      times  

  public final io.reactivex.Completable repeatUntil(io.reactivex.functions.BooleanSupplier);
    descriptor: (Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.BooleanSupplier stop
         0: .line 2025
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            aload 1 /* stop */
            invokevirtual io.reactivex.Flowable.repeatUntil:(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.BooleanSupplier stop
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
            0    1     1  stop  Lio/reactivex/functions/BooleanSupplier;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
      Name  Flags
      stop  

  public final io.reactivex.Completable repeatWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Object>, ? extends org.reactivestreams.Publisher<?>>);
    descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Function handler
         0: .line 2046
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            aload 1 /* handler */
            invokevirtual io.reactivex.Flowable.repeatWhen:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Function handler
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/reactivex/Completable;
            0    1     1  handler  Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Object;>;+Lorg/reactivestreams/Publisher<*>;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Object;>;+Lorg/reactivestreams/Publisher<*>;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
         Name  Flags
      handler  

  public final io.reactivex.Completable retry();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 2062
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            invokevirtual io.reactivex.Flowable.retry:()Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final io.reactivex.Completable retry(io.reactivex.functions.BiPredicate<? super java.lang.Integer, ? super java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.BiPredicate predicate
         0: .line 2081
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            aload 1 /* predicate */
            invokevirtual io.reactivex.Flowable.retry:(Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.BiPredicate predicate
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/Completable;
            0    1     1  predicate  Lio/reactivex/functions/BiPredicate<-Ljava/lang/Integer;-Ljava/lang/Throwable;>;
    Signature: (Lio/reactivex/functions/BiPredicate<-Ljava/lang/Integer;-Ljava/lang/Throwable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
           Name  Flags
      predicate  

  public final io.reactivex.Completable retry(long);
    descriptor: (J)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // long times
         0: .line 2100
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            lload 1 /* times */
            invokevirtual io.reactivex.Flowable.retry:(J)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 1 // long times
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/reactivex/Completable;
            0    1     1  times  J
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
       Name  Flags
      times  

  public final io.reactivex.Completable retry(long, io.reactivex.functions.Predicate<? super java.lang.Throwable>);
    descriptor: (JLio/reactivex/functions/Predicate;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.reactivex.Completable this
        start local 1 // long times
        start local 3 // io.reactivex.functions.Predicate predicate
         0: .line 2124
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            lload 1 /* times */
            aload 3 /* predicate */
            invokevirtual io.reactivex.Flowable.retry:(JLio/reactivex/functions/Predicate;)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 3 // io.reactivex.functions.Predicate predicate
        end local 1 // long times
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/Completable;
            0    1     1      times  J
            0    1     3  predicate  Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;
    Signature: (JLio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
           Name  Flags
      times      
      predicate  

  public final io.reactivex.Completable retry(io.reactivex.functions.Predicate<? super java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/Predicate;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Predicate predicate
         0: .line 2144
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            aload 1 /* predicate */
            invokevirtual io.reactivex.Flowable.retry:(Lio/reactivex/functions/Predicate;)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Predicate predicate
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/Completable;
            0    1     1  predicate  Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;
    Signature: (Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
           Name  Flags
      predicate  

  public final io.reactivex.Completable retryWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Throwable>, ? extends org.reactivestreams.Publisher<?>>);
    descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Function handler
         0: .line 2190
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            aload 1 /* handler */
            invokevirtual io.reactivex.Flowable.retryWhen:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
            invokestatic io.reactivex.Completable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.functions.Function handler
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/reactivex/Completable;
            0    1     1  handler  Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Throwable;>;+Lorg/reactivestreams/Publisher<*>;>;
    Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Throwable;>;+Lorg/reactivestreams/Publisher<*>;>;)Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
         Name  Flags
      handler  

  public final io.reactivex.Completable startWith(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableSource other
         0: .line 2210
            aload 1 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2211
            iconst_2
            anewarray io.reactivex.CompletableSource
            dup
            iconst_0
            aload 1 /* other */
            aastore
            dup
            iconst_1
            aload 0 /* this */
            aastore
            invokestatic io.reactivex.Completable.concatArray:([Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableSource other
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/Completable;
            0    2     1  other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      other  

  public final <T> io.reactivex.Observable<T> startWith(io.reactivex.Observable<T>);
    descriptor: (Lio/reactivex/Observable;)Lio/reactivex/Observable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.Observable other
         0: .line 2232
            aload 1 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2233
            aload 1 /* other */
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toObservable:()Lio/reactivex/Observable;
            invokevirtual io.reactivex.Observable.concatWith:(Lio/reactivex/ObservableSource;)Lio/reactivex/Observable;
            areturn
        end local 1 // io.reactivex.Observable other
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/Completable;
            0    2     1  other  Lio/reactivex/Observable<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Observable<TT;>;)Lio/reactivex/Observable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      other  

  public final <T> io.reactivex.Flowable<T> startWith(org.reactivestreams.Publisher<T>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // org.reactivestreams.Publisher other
         0: .line 2257
            aload 1 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2258
            aload 0 /* this */
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            aload 1 /* other */
            invokevirtual io.reactivex.Flowable.startWith:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
            areturn
        end local 1 // org.reactivestreams.Publisher other
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/Completable;
            0    2     1  other  Lorg/reactivestreams/Publisher<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TT;>;)Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      other  

  public final io.reactivex.Completable hide();
    descriptor: ()Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 2278
            new io.reactivex.internal.operators.completable.CompletableHide
            dup
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.completable.CompletableHide.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/Completable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final io.reactivex.disposables.Disposable subscribe();
    descriptor: ()Lio/reactivex/disposables/Disposable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 2294
            new io.reactivex.internal.observers.EmptyCompletableObserver
            dup
            invokespecial io.reactivex.internal.observers.EmptyCompletableObserver.<init>:()V
            astore 1 /* observer */
        start local 1 // io.reactivex.internal.observers.EmptyCompletableObserver observer
         1: .line 2295
            aload 0 /* this */
            aload 1 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         2: .line 2296
            aload 1 /* observer */
            areturn
        end local 1 // io.reactivex.internal.observers.EmptyCompletableObserver observer
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lio/reactivex/Completable;
            1    3     1  observer  Lio/reactivex/internal/observers/EmptyCompletableObserver;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final void subscribe(io.reactivex.CompletableObserver);
    descriptor: (Lio/reactivex/CompletableObserver;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableObserver observer
         0: .line 2302
            aload 1 /* observer */
            ldc "observer is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2305
            aload 0 /* this */
            aload 1 /* observer */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onSubscribe:(Lio/reactivex/Completable;Lio/reactivex/CompletableObserver;)Lio/reactivex/CompletableObserver;
            astore 1 /* observer */
         2: .line 2307
            aload 1 /* observer */
            ldc "The RxJavaPlugins.onSubscribe hook returned a null CompletableObserver. Please check the handler provided to RxJavaPlugins.setOnCompletableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         3: .line 2309
            aload 0 /* this */
            aload 1 /* observer */
            invokevirtual io.reactivex.Completable.subscribeActual:(Lio/reactivex/CompletableObserver;)V
         4: .line 2310
            goto 11
      StackMap locals:
      StackMap stack: java.lang.NullPointerException
         5: astore 2 /* ex */
        start local 2 // java.lang.NullPointerException ex
         6: .line 2311
            aload 2 /* ex */
            athrow
        end local 2 // java.lang.NullPointerException ex
         7: .line 2312
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* ex */
        start local 2 // java.lang.Throwable ex
         8: .line 2313
            aload 2 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         9: .line 2314
            aload 2 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        10: .line 2315
            aload 2 /* ex */
            invokestatic io.reactivex.Completable.toNpe:(Ljava/lang/Throwable;)Ljava/lang/NullPointerException;
            athrow
        end local 2 // java.lang.Throwable ex
        11: .line 2317
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.reactivex.CompletableObserver observer
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   12     0      this  Lio/reactivex/Completable;
            0   12     1  observer  Lio/reactivex/CompletableObserver;
            6    7     2        ex  Ljava/lang/NullPointerException;
            8   11     2        ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     4       5  Class java.lang.NullPointerException
           1     4       7  Class java.lang.Throwable
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
          Name  Flags
      observer  

  protected abstract void subscribeActual(io.reactivex.CompletableObserver);
    descriptor: (Lio/reactivex/CompletableObserver;)V
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
    MethodParameters:
          Name  Flags
      observer  

  public final <E extends io.reactivex.CompletableObserver> E subscribeWith();
    descriptor: (Lio/reactivex/CompletableObserver;)Lio/reactivex/CompletableObserver;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableObserver observer
         0: .line 2358
            aload 0 /* this */
            aload 1 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         1: .line 2359
            aload 1 /* observer */
            areturn
        end local 1 // io.reactivex.CompletableObserver observer
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lio/reactivex/Completable;
            0    2     1  observer  TE;
    Signature: <E::Lio/reactivex/CompletableObserver;>(TE;)TE;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
          Name  Flags
      observer  

  public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.Action, io.reactivex.functions.Consumer<? super java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Action onComplete
        start local 2 // io.reactivex.functions.Consumer onError
         0: .line 2379
            aload 2 /* onError */
            ldc "onError is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2380
            aload 1 /* onComplete */
            ldc "onComplete is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 2382
            new io.reactivex.internal.observers.CallbackCompletableObserver
            dup
            aload 2 /* onError */
            aload 1 /* onComplete */
            invokespecial io.reactivex.internal.observers.CallbackCompletableObserver.<init>:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)V
            astore 3 /* observer */
        start local 3 // io.reactivex.internal.observers.CallbackCompletableObserver observer
         3: .line 2383
            aload 0 /* this */
            aload 3 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         4: .line 2384
            aload 3 /* observer */
            areturn
        end local 3 // io.reactivex.internal.observers.CallbackCompletableObserver observer
        end local 2 // io.reactivex.functions.Consumer onError
        end local 1 // io.reactivex.functions.Action onComplete
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lio/reactivex/Completable;
            0    5     1  onComplete  Lio/reactivex/functions/Action;
            0    5     2     onError  Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
            3    5     3    observer  Lio/reactivex/internal/observers/CallbackCompletableObserver;
    Signature: (Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/reactivex/disposables/Disposable;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      onComplete  final
      onError     final

  public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Action onComplete
         0: .line 2407
            aload 1 /* onComplete */
            ldc "onComplete is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2409
            new io.reactivex.internal.observers.CallbackCompletableObserver
            dup
            aload 1 /* onComplete */
            invokespecial io.reactivex.internal.observers.CallbackCompletableObserver.<init>:(Lio/reactivex/functions/Action;)V
            astore 2 /* observer */
        start local 2 // io.reactivex.internal.observers.CallbackCompletableObserver observer
         2: .line 2410
            aload 0 /* this */
            aload 2 /* observer */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         3: .line 2411
            aload 2 /* observer */
            areturn
        end local 2 // io.reactivex.internal.observers.CallbackCompletableObserver observer
        end local 1 // io.reactivex.functions.Action onComplete
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lio/reactivex/Completable;
            0    4     1  onComplete  Lio/reactivex/functions/Action;
            2    4     2    observer  Lio/reactivex/internal/observers/CallbackCompletableObserver;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      onComplete  final

  public final io.reactivex.Completable subscribeOn(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.Scheduler scheduler
         0: .line 2431
            aload 1 /* scheduler */
            ldc "scheduler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2433
            new io.reactivex.internal.operators.completable.CompletableSubscribeOn
            dup
            aload 0 /* this */
            aload 1 /* scheduler */
            invokespecial io.reactivex.internal.operators.completable.CompletableSubscribeOn.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/Scheduler;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.Scheduler scheduler
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/reactivex/Completable;
            0    2     1  scheduler  Lio/reactivex/Scheduler;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      scheduler  final

  public final io.reactivex.Completable takeUntil(io.reactivex.CompletableSource);
    descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.CompletableSource other
         0: .line 2458
            aload 1 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2460
            new io.reactivex.internal.operators.completable.CompletableTakeUntilCompletable
            dup
            aload 0 /* this */
            aload 1 /* other */
            invokespecial io.reactivex.internal.operators.completable.CompletableTakeUntilCompletable.<init>:(Lio/reactivex/Completable;Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.CompletableSource other
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/Completable;
            0    2     1  other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      other  

  public final io.reactivex.Completable timeout(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=4, args_size=3
        start local 0 // io.reactivex.Completable this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
         0: .line 2480
            aload 0 /* this */
            lload 1 /* timeout */
            aload 3 /* unit */
            invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
            aconst_null
            invokevirtual io.reactivex.Completable.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/reactivex/Completable;
            0    1     1  timeout  J
            0    1     3     unit  Ljava/util/concurrent/TimeUnit;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
    MethodParameters:
         Name  Flags
      timeout  
      unit     

  public final io.reactivex.Completable timeout(long, java.util.concurrent.TimeUnit, io.reactivex.CompletableSource);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // io.reactivex.Completable this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
        start local 4 // io.reactivex.CompletableSource other
         0: .line 2503
            aload 4 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2504
            aload 0 /* this */
            lload 1 /* timeout */
            aload 3 /* unit */
            invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
            aload 4 /* other */
            invokevirtual io.reactivex.Completable.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 4 // io.reactivex.CompletableSource other
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/reactivex/Completable;
            0    2     1  timeout  J
            0    2     3     unit  Ljava/util/concurrent/TimeUnit;
            0    2     4    other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      timeout  
      unit     
      other    

  public final io.reactivex.Completable timeout(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // io.reactivex.Completable this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
        start local 4 // io.reactivex.Scheduler scheduler
         0: .line 2526
            aload 0 /* this */
            lload 1 /* timeout */
            aload 3 /* unit */
            aload 4 /* scheduler */
            aconst_null
            invokevirtual io.reactivex.Completable.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 4 // io.reactivex.Scheduler scheduler
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/Completable;
            0    1     1    timeout  J
            0    1     3       unit  Ljava/util/concurrent/TimeUnit;
            0    1     4  scheduler  Lio/reactivex/Scheduler;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    MethodParameters:
           Name  Flags
      timeout    
      unit       
      scheduler  

  public final io.reactivex.Completable timeout(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, io.reactivex.CompletableSource);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=6, args_size=5
        start local 0 // io.reactivex.Completable this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
        start local 4 // io.reactivex.Scheduler scheduler
        start local 5 // io.reactivex.CompletableSource other
         0: .line 2551
            aload 5 /* other */
            ldc "other is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2552
            aload 0 /* this */
            lload 1 /* timeout */
            aload 3 /* unit */
            aload 4 /* scheduler */
            aload 5 /* other */
            invokevirtual io.reactivex.Completable.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
            areturn
        end local 5 // io.reactivex.CompletableSource other
        end local 4 // io.reactivex.Scheduler scheduler
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/reactivex/Completable;
            0    2     1    timeout  J
            0    2     3       unit  Ljava/util/concurrent/TimeUnit;
            0    2     4  scheduler  Lio/reactivex/Scheduler;
            0    2     5      other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      timeout    
      unit       
      scheduler  
      other      

  private io.reactivex.Completable timeout0(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, io.reactivex.CompletableSource);
    descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/CompletableSource;)Lio/reactivex/Completable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=8, locals=6, args_size=5
        start local 0 // io.reactivex.Completable this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
        start local 4 // io.reactivex.Scheduler scheduler
        start local 5 // io.reactivex.CompletableSource other
         0: .line 2575
            aload 3 /* unit */
            ldc "unit is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2576
            aload 4 /* scheduler */
            ldc "scheduler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 2577
            new io.reactivex.internal.operators.completable.CompletableTimeout
            dup
            aload 0 /* this */
            lload 1 /* timeout */
            aload 3 /* unit */
            aload 4 /* scheduler */
            aload 5 /* other */
            invokespecial io.reactivex.internal.operators.completable.CompletableTimeout.<init>:(Lio/reactivex/CompletableSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 5 // io.reactivex.CompletableSource other
        end local 4 // io.reactivex.Scheduler scheduler
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/reactivex/Completable;
            0    3     1    timeout  J
            0    3     3       unit  Ljava/util/concurrent/TimeUnit;
            0    3     4  scheduler  Lio/reactivex/Scheduler;
            0    3     5      other  Lio/reactivex/CompletableSource;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      timeout    
      unit       
      scheduler  
      other      

  public final <U> U to(io.reactivex.functions.Function<? super io.reactivex.Completable, U>);
    descriptor: (Lio/reactivex/functions/Function;)Ljava/lang/Object;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.functions.Function converter
         0: .line 2597
            aload 1 /* converter */
            ldc "converter is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.functions.Function
            aload 0 /* this */
            invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
         1: areturn
         2: .line 2598
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* ex */
        start local 2 // java.lang.Throwable ex
         3: .line 2599
            aload 2 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         4: .line 2600
            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 // io.reactivex.functions.Function converter
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0       this  Lio/reactivex/Completable;
            0    5     1  converter  Lio/reactivex/functions/Function<-Lio/reactivex/Completable;TU;>;
            3    5     2         ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
    Signature: <U:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-Lio/reactivex/Completable;TU;>;)TU;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
           Name  Flags
      converter  

  public final <T> io.reactivex.Flowable<T> toFlowable();
    descriptor: ()Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 2623
            aload 0 /* this */
            instanceof io.reactivex.internal.fuseable.FuseToFlowable
            ifeq 2
         1: .line 2624
            aload 0 /* this */
            checkcast io.reactivex.internal.fuseable.FuseToFlowable
            invokeinterface io.reactivex.internal.fuseable.FuseToFlowable.fuseToFlowable:()Lio/reactivex/Flowable;
            areturn
         2: .line 2626
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.completable.CompletableToFlowable
            dup
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.completable.CompletableToFlowable.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactivex/Completable;
    Signature: <T:Ljava/lang/Object;>()Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final <T> io.reactivex.Maybe<T> toMaybe();
    descriptor: ()Lio/reactivex/Maybe;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 2646
            aload 0 /* this */
            instanceof io.reactivex.internal.fuseable.FuseToMaybe
            ifeq 2
         1: .line 2647
            aload 0 /* this */
            checkcast io.reactivex.internal.fuseable.FuseToMaybe
            invokeinterface io.reactivex.internal.fuseable.FuseToMaybe.fuseToMaybe:()Lio/reactivex/Maybe;
            areturn
         2: .line 2649
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.maybe.MaybeFromCompletable
            dup
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.maybe.MaybeFromCompletable.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactivex/Completable;
    Signature: <T:Ljava/lang/Object;>()Lio/reactivex/Maybe<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final <T> io.reactivex.Observable<T> toObservable();
    descriptor: ()Lio/reactivex/Observable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 2668
            aload 0 /* this */
            instanceof io.reactivex.internal.fuseable.FuseToObservable
            ifeq 2
         1: .line 2669
            aload 0 /* this */
            checkcast io.reactivex.internal.fuseable.FuseToObservable
            invokeinterface io.reactivex.internal.fuseable.FuseToObservable.fuseToObservable:()Lio/reactivex/Observable;
            areturn
         2: .line 2671
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.completable.CompletableToObservable
            dup
            aload 0 /* this */
            invokespecial io.reactivex.internal.operators.completable.CompletableToObservable.<init>:(Lio/reactivex/CompletableSource;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Observable;)Lio/reactivex/Observable;
            areturn
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactivex/Completable;
    Signature: <T:Ljava/lang/Object;>()Lio/reactivex/Observable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final <T> io.reactivex.Single<T> toSingle(java.util.concurrent.Callable<? extends T>);
    descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Single;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // java.util.concurrent.Callable completionValueSupplier
         0: .line 2692
            aload 1 /* completionValueSupplier */
            ldc "completionValueSupplier is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2693
            new io.reactivex.internal.operators.completable.CompletableToSingle
            dup
            aload 0 /* this */
            aload 1 /* completionValueSupplier */
            aconst_null
            invokespecial io.reactivex.internal.operators.completable.CompletableToSingle.<init>:(Lio/reactivex/CompletableSource;Ljava/util/concurrent/Callable;Ljava/lang/Object;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
            areturn
        end local 1 // java.util.concurrent.Callable completionValueSupplier
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot                     Name  Signature
            0    2     0                     this  Lio/reactivex/Completable;
            0    2     1  completionValueSupplier  Ljava/util/concurrent/Callable<+TT;>;
    Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+TT;>;)Lio/reactivex/Single<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
                         Name  Flags
      completionValueSupplier  final

  public final <T> io.reactivex.Single<T> toSingleDefault(T);
    descriptor: (Ljava/lang/Object;)Lio/reactivex/Single;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // java.lang.Object completionValue
         0: .line 2714
            aload 1 /* completionValue */
            ldc "completionValue is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2715
            new io.reactivex.internal.operators.completable.CompletableToSingle
            dup
            aload 0 /* this */
            aconst_null
            aload 1 /* completionValue */
            invokespecial io.reactivex.internal.operators.completable.CompletableToSingle.<init>:(Lio/reactivex/CompletableSource;Ljava/util/concurrent/Callable;Ljava/lang/Object;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
            areturn
        end local 1 // java.lang.Object completionValue
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    2     0             this  Lio/reactivex/Completable;
            0    2     1  completionValue  TT;
    Signature: <T:Ljava/lang/Object;>(TT;)Lio/reactivex/Single<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
                 Name  Flags
      completionValue  final

  public final io.reactivex.Completable unsubscribeOn(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // io.reactivex.Scheduler scheduler
         0: .line 2735
            aload 1 /* scheduler */
            ldc "scheduler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 2736
            new io.reactivex.internal.operators.completable.CompletableDisposeOn
            dup
            aload 0 /* this */
            aload 1 /* scheduler */
            invokespecial io.reactivex.internal.operators.completable.CompletableDisposeOn.<init>:(Lio/reactivex/CompletableSource;Lio/reactivex/Scheduler;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
            areturn
        end local 1 // io.reactivex.Scheduler scheduler
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/reactivex/Completable;
            0    2     1  scheduler  Lio/reactivex/Scheduler;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "custom")
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      scheduler  final

  public final io.reactivex.observers.TestObserver<java.lang.Void> test();
    descriptor: ()Lio/reactivex/observers/TestObserver;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.Completable this
         0: .line 2757
            new io.reactivex.observers.TestObserver
            dup
            invokespecial io.reactivex.observers.TestObserver.<init>:()V
            astore 1 /* to */
        start local 1 // io.reactivex.observers.TestObserver to
         1: .line 2758
            aload 0 /* this */
            aload 1 /* to */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         2: .line 2759
            aload 1 /* to */
            areturn
        end local 1 // io.reactivex.observers.TestObserver to
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactivex/Completable;
            1    3     1    to  Lio/reactivex/observers/TestObserver<Ljava/lang/Void;>;
    Signature: ()Lio/reactivex/observers/TestObserver<Ljava/lang/Void;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")

  public final io.reactivex.observers.TestObserver<java.lang.Void> test(boolean);
    descriptor: (Z)Lio/reactivex/observers/TestObserver;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.reactivex.Completable this
        start local 1 // boolean cancelled
         0: .line 2778
            new io.reactivex.observers.TestObserver
            dup
            invokespecial io.reactivex.observers.TestObserver.<init>:()V
            astore 2 /* to */
        start local 2 // io.reactivex.observers.TestObserver to
         1: .line 2780
            iload 1 /* cancelled */
            ifeq 3
         2: .line 2781
            aload 2 /* to */
            invokevirtual io.reactivex.observers.TestObserver.cancel:()V
         3: .line 2783
      StackMap locals: io.reactivex.observers.TestObserver
      StackMap stack:
            aload 0 /* this */
            aload 2 /* to */
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/CompletableObserver;)V
         4: .line 2784
            aload 2 /* to */
            areturn
        end local 2 // io.reactivex.observers.TestObserver to
        end local 1 // boolean cancelled
        end local 0 // io.reactivex.Completable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0       this  Lio/reactivex/Completable;
            0    5     1  cancelled  Z
            1    5     2         to  Lio/reactivex/observers/TestObserver<Ljava/lang/Void;>;
    Signature: (Z)Lio/reactivex/observers/TestObserver<Ljava/lang/Void;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
      io.reactivex.annotations.SchedulerSupport(value = "none")
    MethodParameters:
           Name  Flags
      cancelled  
}
SourceFile: "Completable.java"