public abstract class io.reactivex.parallel.ParallelFlowable<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: io.reactivex.parallel.ParallelFlowable
  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.parallel.ParallelFlowable this
         0: .line 41
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/parallel/ParallelFlowable<TT;>;

  public abstract void subscribe(org.reactivestreams.Subscriber<? super T>[]);
    descriptor: ([Lorg/reactivestreams/Subscriber;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ([Lorg/reactivestreams/Subscriber<-TT;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
             Name  Flags
      subscribers  

  public abstract int parallelism();
    descriptor: ()I
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  protected final boolean validate(org.reactivestreams.Subscriber<?>[]);
    descriptor: ([Lorg/reactivestreams/Subscriber;)Z
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Code:
      stack=5, locals=8, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // org.reactivestreams.Subscriber[] subscribers
         0: .line 67
            aload 0 /* this */
            invokevirtual io.reactivex.parallel.ParallelFlowable.parallelism:()I
            istore 2 /* p */
        start local 2 // int p
         1: .line 68
            aload 1 /* subscribers */
            arraylength
            iload 2 /* p */
            if_icmpeq 9
         2: .line 69
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "parallelism = "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 2 /* p */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ", subscribers = "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* subscribers */
            arraylength
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            astore 3 /* iae */
        start local 3 // java.lang.Throwable iae
         3: .line 70
            aload 1 /* subscribers */
            dup
            astore 7
            arraylength
            istore 6
            iconst_0
            istore 5
            goto 7
      StackMap locals: io.reactivex.parallel.ParallelFlowable org.reactivestreams.Subscriber[] int java.lang.Throwable top int int org.reactivestreams.Subscriber[]
      StackMap stack:
         4: aload 7
            iload 5
            aaload
            astore 4 /* s */
        start local 4 // org.reactivestreams.Subscriber s
         5: .line 71
            aload 3 /* iae */
            aload 4 /* s */
            invokestatic io.reactivex.internal.subscriptions.EmptySubscription.error:(Ljava/lang/Throwable;Lorg/reactivestreams/Subscriber;)V
        end local 4 // org.reactivestreams.Subscriber s
         6: .line 70
            iinc 5 1
      StackMap locals:
      StackMap stack:
         7: iload 5
            iload 6
            if_icmplt 4
         8: .line 73
            iconst_0
            ireturn
        end local 3 // java.lang.Throwable iae
         9: .line 75
      StackMap locals: io.reactivex.parallel.ParallelFlowable org.reactivestreams.Subscriber[] int
      StackMap stack:
            iconst_1
            ireturn
        end local 2 // int p
        end local 1 // org.reactivestreams.Subscriber[] subscribers
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   10     0         this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   10     1  subscribers  [Lorg/reactivestreams/Subscriber;
            1   10     2            p  I
            3    9     3          iae  Ljava/lang/Throwable;
            5    6     4            s  Lorg/reactivestreams/Subscriber<*>;
    Signature: ([Lorg/reactivestreams/Subscriber<*>;)Z
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
             Name  Flags
      subscribers  

  public static <T> io.reactivex.parallel.ParallelFlowable<T> from(org.reactivestreams.Publisher<? extends T>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher source
         0: .line 87
            aload 0 /* source */
            invokestatic java.lang.Runtime.getRuntime:()Ljava/lang/Runtime;
            invokevirtual java.lang.Runtime.availableProcessors:()I
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokestatic io.reactivex.parallel.ParallelFlowable.from:(Lorg/reactivestreams/Publisher;II)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Lorg/reactivestreams/Publisher<+TT;>;
    Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      source  

  public static <T> io.reactivex.parallel.ParallelFlowable<T> from(org.reactivestreams.Publisher<? extends T>, int);
    descriptor: (Lorg/reactivestreams/Publisher;I)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.reactivestreams.Publisher source
        start local 1 // int parallelism
         0: .line 99
            aload 0 /* source */
            iload 1 /* parallelism */
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokestatic io.reactivex.parallel.ParallelFlowable.from:(Lorg/reactivestreams/Publisher;II)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // int parallelism
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    1     0       source  Lorg/reactivestreams/Publisher<+TT;>;
            0    1     1  parallelism  I
    Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;I)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
             Name  Flags
      source       
      parallelism  

  public static <T> io.reactivex.parallel.ParallelFlowable<T> from(org.reactivestreams.Publisher<? extends T>, int, int);
    descriptor: (Lorg/reactivestreams/Publisher;II)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // org.reactivestreams.Publisher source
        start local 1 // int parallelism
        start local 2 // int prefetch
         0: .line 117
            aload 0 /* source */
            ldc "source"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 118
            iload 1 /* parallelism */
            ldc "parallelism"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 119
            iload 2 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         3: .line 121
            new io.reactivex.internal.operators.parallel.ParallelFromPublisher
            dup
            aload 0 /* source */
            iload 1 /* parallelism */
            iload 2 /* prefetch */
            invokespecial io.reactivex.internal.operators.parallel.ParallelFromPublisher.<init>:(Lorg/reactivestreams/Publisher;II)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // int prefetch
        end local 1 // int parallelism
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0       source  Lorg/reactivestreams/Publisher<+TT;>;
            0    4     1  parallelism  I
            0    4     2     prefetch  I
    Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;II)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
    MethodParameters:
             Name  Flags
      source       
      parallelism  
      prefetch     

  public final <R> R as(io.reactivex.parallel.ParallelFlowableConverter<T, R>);
    descriptor: (Lio/reactivex/parallel/ParallelFlowableConverter;)Ljava/lang/Object;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.parallel.ParallelFlowableConverter converter
         0: .line 138
            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.parallel.ParallelFlowableConverter
            aload 0 /* this */
            invokeinterface io.reactivex.parallel.ParallelFlowableConverter.apply:(Lio/reactivex/parallel/ParallelFlowable;)Ljava/lang/Object;
            areturn
        end local 1 // io.reactivex.parallel.ParallelFlowableConverter converter
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1  converter  Lio/reactivex/parallel/ParallelFlowableConverter<TT;TR;>;
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/parallel/ParallelFlowableConverter<TT;TR;>;)TR;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      converter  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> map(io.reactivex.functions.Function<? super T, ? extends R>);
    descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
         0: .line 152
            aload 1 /* mapper */
            ldc "mapper"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 153
            new io.reactivex.internal.operators.parallel.ParallelMap
            dup
            aload 0 /* this */
            aload 1 /* mapper */
            invokespecial io.reactivex.internal.operators.parallel.ParallelMap.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Function;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    2     1  mapper  Lio/reactivex/functions/Function<-TT;+TR;>;
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+TR;>;)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      mapper  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> map(io.reactivex.functions.Function<? super T, ? extends R>, io.reactivex.parallel.ParallelFailureHandling);
    descriptor: (Lio/reactivex/functions/Function;Lio/reactivex/parallel/ParallelFailureHandling;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // io.reactivex.parallel.ParallelFailureHandling errorHandler
         0: .line 172
            aload 1 /* mapper */
            ldc "mapper"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 173
            aload 2 /* errorHandler */
            ldc "errorHandler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 174
            new io.reactivex.internal.operators.parallel.ParallelMapTry
            dup
            aload 0 /* this */
            aload 1 /* mapper */
            aload 2 /* errorHandler */
            invokespecial io.reactivex.internal.operators.parallel.ParallelMapTry.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.parallel.ParallelFailureHandling errorHandler
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1        mapper  Lio/reactivex/functions/Function<-TT;+TR;>;
            0    3     2  errorHandler  Lio/reactivex/parallel/ParallelFailureHandling;
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+TR;>;Lio/reactivex/parallel/ParallelFailureHandling;)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
              Name  Flags
      mapper        
      errorHandler  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> map(io.reactivex.functions.Function<? super T, ? extends R>, io.reactivex.functions.BiFunction<? super java.lang.Long, ? super java.lang.Throwable, io.reactivex.parallel.ParallelFailureHandling>);
    descriptor: (Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // io.reactivex.functions.BiFunction errorHandler
         0: .line 194
            aload 1 /* mapper */
            ldc "mapper"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 195
            aload 2 /* errorHandler */
            ldc "errorHandler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 196
            new io.reactivex.internal.operators.parallel.ParallelMapTry
            dup
            aload 0 /* this */
            aload 1 /* mapper */
            aload 2 /* errorHandler */
            invokespecial io.reactivex.internal.operators.parallel.ParallelMapTry.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.functions.BiFunction errorHandler
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1        mapper  Lio/reactivex/functions/Function<-TT;+TR;>;
            0    3     2  errorHandler  Lio/reactivex/functions/BiFunction<-Ljava/lang/Long;-Ljava/lang/Throwable;Lio/reactivex/parallel/ParallelFailureHandling;>;
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+TR;>;Lio/reactivex/functions/BiFunction<-Ljava/lang/Long;-Ljava/lang/Throwable;Lio/reactivex/parallel/ParallelFailureHandling;>;)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
              Name  Flags
      mapper        
      errorHandler  

  public final io.reactivex.parallel.ParallelFlowable<T> filter(io.reactivex.functions.Predicate<? super T>);
    descriptor: (Lio/reactivex/functions/Predicate;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Predicate predicate
         0: .line 208
            aload 1 /* predicate */
            ldc "predicate"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 209
            new io.reactivex.internal.operators.parallel.ParallelFilter
            dup
            aload 0 /* this */
            aload 1 /* predicate */
            invokespecial io.reactivex.internal.operators.parallel.ParallelFilter.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Predicate;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Predicate predicate
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    2     1  predicate  Lio/reactivex/functions/Predicate<-TT;>;
    Signature: (Lio/reactivex/functions/Predicate<-TT;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      predicate  

  public final io.reactivex.parallel.ParallelFlowable<T> filter(io.reactivex.functions.Predicate<? super T>, io.reactivex.parallel.ParallelFailureHandling);
    descriptor: (Lio/reactivex/functions/Predicate;Lio/reactivex/parallel/ParallelFailureHandling;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Predicate predicate
        start local 2 // io.reactivex.parallel.ParallelFailureHandling errorHandler
         0: .line 226
            aload 1 /* predicate */
            ldc "predicate"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 227
            aload 2 /* errorHandler */
            ldc "errorHandler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 228
            new io.reactivex.internal.operators.parallel.ParallelFilterTry
            dup
            aload 0 /* this */
            aload 1 /* predicate */
            aload 2 /* errorHandler */
            invokespecial io.reactivex.internal.operators.parallel.ParallelFilterTry.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Predicate;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.parallel.ParallelFailureHandling errorHandler
        end local 1 // io.reactivex.functions.Predicate predicate
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1     predicate  Lio/reactivex/functions/Predicate<-TT;>;
            0    3     2  errorHandler  Lio/reactivex/parallel/ParallelFailureHandling;
    Signature: (Lio/reactivex/functions/Predicate<-TT;>;Lio/reactivex/parallel/ParallelFailureHandling;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
              Name  Flags
      predicate     
      errorHandler  

  public final io.reactivex.parallel.ParallelFlowable<T> filter(io.reactivex.functions.Predicate<? super T>, io.reactivex.functions.BiFunction<? super java.lang.Long, ? super java.lang.Throwable, io.reactivex.parallel.ParallelFailureHandling>);
    descriptor: (Lio/reactivex/functions/Predicate;Lio/reactivex/functions/BiFunction;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Predicate predicate
        start local 2 // io.reactivex.functions.BiFunction errorHandler
         0: .line 246
            aload 1 /* predicate */
            ldc "predicate"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 247
            aload 2 /* errorHandler */
            ldc "errorHandler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 248
            new io.reactivex.internal.operators.parallel.ParallelFilterTry
            dup
            aload 0 /* this */
            aload 1 /* predicate */
            aload 2 /* errorHandler */
            invokespecial io.reactivex.internal.operators.parallel.ParallelFilterTry.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Predicate;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.functions.BiFunction errorHandler
        end local 1 // io.reactivex.functions.Predicate predicate
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1     predicate  Lio/reactivex/functions/Predicate<-TT;>;
            0    3     2  errorHandler  Lio/reactivex/functions/BiFunction<-Ljava/lang/Long;-Ljava/lang/Throwable;Lio/reactivex/parallel/ParallelFailureHandling;>;
    Signature: (Lio/reactivex/functions/Predicate<-TT;>;Lio/reactivex/functions/BiFunction<-Ljava/lang/Long;-Ljava/lang/Throwable;Lio/reactivex/parallel/ParallelFailureHandling;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
              Name  Flags
      predicate     
      errorHandler  

  public final io.reactivex.parallel.ParallelFlowable<T> runOn(io.reactivex.Scheduler);
    descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.Scheduler scheduler
         0: .line 273
            aload 0 /* this */
            aload 1 /* scheduler */
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokevirtual io.reactivex.parallel.ParallelFlowable.runOn:(Lio/reactivex/Scheduler;I)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.Scheduler scheduler
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1  scheduler  Lio/reactivex/Scheduler;
    Signature: (Lio/reactivex/Scheduler;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      scheduler  

  public final io.reactivex.parallel.ParallelFlowable<T> runOn(io.reactivex.Scheduler, int);
    descriptor: (Lio/reactivex/Scheduler;I)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.Scheduler scheduler
        start local 2 // int prefetch
         0: .line 300
            aload 1 /* scheduler */
            ldc "scheduler"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 301
            iload 2 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 302
            new io.reactivex.internal.operators.parallel.ParallelRunOn
            dup
            aload 0 /* this */
            aload 1 /* scheduler */
            iload 2 /* prefetch */
            invokespecial io.reactivex.internal.operators.parallel.ParallelRunOn.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/Scheduler;I)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // int prefetch
        end local 1 // io.reactivex.Scheduler scheduler
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1  scheduler  Lio/reactivex/Scheduler;
            0    3     2   prefetch  I
    Signature: (Lio/reactivex/Scheduler;I)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
           Name  Flags
      scheduler  
      prefetch   

  public final io.reactivex.Flowable<T> reduce(io.reactivex.functions.BiFunction<T, T, T>);
    descriptor: (Lio/reactivex/functions/BiFunction;)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.BiFunction reducer
         0: .line 316
            aload 1 /* reducer */
            ldc "reducer"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 317
            new io.reactivex.internal.operators.parallel.ParallelReduceFull
            dup
            aload 0 /* this */
            aload 1 /* reducer */
            invokespecial io.reactivex.internal.operators.parallel.ParallelReduceFull.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
            areturn
        end local 1 // io.reactivex.functions.BiFunction reducer
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    2     1  reducer  Lio/reactivex/functions/BiFunction<TT;TT;TT;>;
    Signature: (Lio/reactivex/functions/BiFunction<TT;TT;TT;>;)Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      reducer  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> reduce(java.util.concurrent.Callable<R>, io.reactivex.functions.BiFunction<R, ? super T, R>);
    descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/BiFunction;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // java.util.concurrent.Callable initialSupplier
        start local 2 // io.reactivex.functions.BiFunction reducer
         0: .line 334
            aload 1 /* initialSupplier */
            ldc "initialSupplier"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 335
            aload 2 /* reducer */
            ldc "reducer"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 336
            new io.reactivex.internal.operators.parallel.ParallelReduce
            dup
            aload 0 /* this */
            aload 1 /* initialSupplier */
            aload 2 /* reducer */
            invokespecial io.reactivex.internal.operators.parallel.ParallelReduce.<init>:(Lio/reactivex/parallel/ParallelFlowable;Ljava/util/concurrent/Callable;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.functions.BiFunction reducer
        end local 1 // java.util.concurrent.Callable initialSupplier
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1  initialSupplier  Ljava/util/concurrent/Callable<TR;>;
            0    3     2          reducer  Lio/reactivex/functions/BiFunction<TR;-TT;TR;>;
    Signature: <R:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<TR;>;Lio/reactivex/functions/BiFunction<TR;-TT;TR;>;)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                 Name  Flags
      initialSupplier  
      reducer          

  public final io.reactivex.Flowable<T> sequential();
    descriptor: ()Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.parallel.ParallelFlowable this
         0: .line 360
            aload 0 /* this */
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokevirtual io.reactivex.parallel.ParallelFlowable.sequential:(I)Lio/reactivex/Flowable;
            areturn
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
    Signature: ()Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.CheckReturnValue()

  public final io.reactivex.Flowable<T> sequential(int);
    descriptor: (I)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // int prefetch
         0: .line 384
            iload 1 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         1: .line 385
            new io.reactivex.internal.operators.parallel.ParallelJoin
            dup
            aload 0 /* this */
            iload 1 /* prefetch */
            iconst_0
            invokespecial io.reactivex.internal.operators.parallel.ParallelJoin.<init>:(Lio/reactivex/parallel/ParallelFlowable;IZ)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
            areturn
        end local 1 // int prefetch
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    2     1  prefetch  I
    Signature: (I)Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      prefetch  

  public final io.reactivex.Flowable<T> sequentialDelayError();
    descriptor: ()Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.parallel.ParallelFlowable this
         0: .line 412
            aload 0 /* this */
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokevirtual io.reactivex.parallel.ParallelFlowable.sequentialDelayError:(I)Lio/reactivex/Flowable;
            areturn
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
    Signature: ()Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()

  public final io.reactivex.Flowable<T> sequentialDelayError(int);
    descriptor: (I)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // int prefetch
         0: .line 438
            iload 1 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         1: .line 439
            new io.reactivex.internal.operators.parallel.ParallelJoin
            dup
            aload 0 /* this */
            iload 1 /* prefetch */
            iconst_1
            invokespecial io.reactivex.internal.operators.parallel.ParallelJoin.<init>:(Lio/reactivex/parallel/ParallelFlowable;IZ)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
            areturn
        end local 1 // int prefetch
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    2     1  prefetch  I
    Signature: (I)Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
      io.reactivex.annotations.SchedulerSupport(value = "none")
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      prefetch  

  public final io.reactivex.Flowable<T> sorted(java.util.Comparator<? super T>);
    descriptor: (Ljava/util/Comparator;)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // java.util.Comparator comparator
         0: .line 454
            aload 0 /* this */
            aload 1 /* comparator */
            bipush 16
            invokevirtual io.reactivex.parallel.ParallelFlowable.sorted:(Ljava/util/Comparator;I)Lio/reactivex/Flowable;
            areturn
        end local 1 // java.util.Comparator comparator
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1  comparator  Ljava/util/Comparator<-TT;>;
    Signature: (Ljava/util/Comparator<-TT;>;)Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      comparator  

  public final io.reactivex.Flowable<T> sorted(java.util.Comparator<? super T>, int);
    descriptor: (Ljava/util/Comparator;I)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=6, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // java.util.Comparator comparator
        start local 2 // int capacityHint
         0: .line 470
            aload 1 /* comparator */
            ldc "comparator is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 471
            iload 2 /* capacityHint */
            ldc "capacityHint"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 472
            iload 2 /* capacityHint */
            aload 0 /* this */
            invokevirtual io.reactivex.parallel.ParallelFlowable.parallelism:()I
            idiv
            iconst_1
            iadd
            istore 3 /* ch */
        start local 3 // int ch
         3: .line 473
            aload 0 /* this */
            iload 3 /* ch */
            invokestatic io.reactivex.internal.functions.Functions.createArrayList:(I)Ljava/util/concurrent/Callable;
            invokestatic io.reactivex.internal.util.ListAddBiConsumer.instance:()Lio/reactivex/functions/BiFunction;
            invokevirtual io.reactivex.parallel.ParallelFlowable.reduce:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/BiFunction;)Lio/reactivex/parallel/ParallelFlowable;
            astore 4 /* railReduced */
        start local 4 // io.reactivex.parallel.ParallelFlowable railReduced
         4: .line 474
            aload 4 /* railReduced */
            new io.reactivex.internal.util.SorterFunction
            dup
            aload 1 /* comparator */
            invokespecial io.reactivex.internal.util.SorterFunction.<init>:(Ljava/util/Comparator;)V
            invokevirtual io.reactivex.parallel.ParallelFlowable.map:(Lio/reactivex/functions/Function;)Lio/reactivex/parallel/ParallelFlowable;
            astore 5 /* railSorted */
        start local 5 // io.reactivex.parallel.ParallelFlowable railSorted
         5: .line 476
            new io.reactivex.internal.operators.parallel.ParallelSortedJoin
            dup
            aload 5 /* railSorted */
            aload 1 /* comparator */
            invokespecial io.reactivex.internal.operators.parallel.ParallelSortedJoin.<init>:(Lio/reactivex/parallel/ParallelFlowable;Ljava/util/Comparator;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
            areturn
        end local 5 // io.reactivex.parallel.ParallelFlowable railSorted
        end local 4 // io.reactivex.parallel.ParallelFlowable railReduced
        end local 3 // int ch
        end local 2 // int capacityHint
        end local 1 // java.util.Comparator comparator
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    6     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    6     1    comparator  Ljava/util/Comparator<-TT;>;
            0    6     2  capacityHint  I
            3    6     3            ch  I
            4    6     4   railReduced  Lio/reactivex/parallel/ParallelFlowable<Ljava/util/List<TT;>;>;
            5    6     5    railSorted  Lio/reactivex/parallel/ParallelFlowable<Ljava/util/List<TT;>;>;
    Signature: (Ljava/util/Comparator<-TT;>;I)Lio/reactivex/Flowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
              Name  Flags
      comparator    
      capacityHint  

  public final io.reactivex.Flowable<java.util.List<T>> toSortedList(java.util.Comparator<? super T>);
    descriptor: (Ljava/util/Comparator;)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // java.util.Comparator comparator
         0: .line 490
            aload 0 /* this */
            aload 1 /* comparator */
            bipush 16
            invokevirtual io.reactivex.parallel.ParallelFlowable.toSortedList:(Ljava/util/Comparator;I)Lio/reactivex/Flowable;
            areturn
        end local 1 // java.util.Comparator comparator
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1  comparator  Ljava/util/Comparator<-TT;>;
    Signature: (Ljava/util/Comparator<-TT;>;)Lio/reactivex/Flowable<Ljava/util/List<TT;>;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      comparator  

  public final io.reactivex.Flowable<java.util.List<T>> toSortedList(java.util.Comparator<? super T>, int);
    descriptor: (Ljava/util/Comparator;I)Lio/reactivex/Flowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=7, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // java.util.Comparator comparator
        start local 2 // int capacityHint
         0: .line 504
            aload 1 /* comparator */
            ldc "comparator is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 505
            iload 2 /* capacityHint */
            ldc "capacityHint"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 507
            iload 2 /* capacityHint */
            aload 0 /* this */
            invokevirtual io.reactivex.parallel.ParallelFlowable.parallelism:()I
            idiv
            iconst_1
            iadd
            istore 3 /* ch */
        start local 3 // int ch
         3: .line 508
            aload 0 /* this */
            iload 3 /* ch */
            invokestatic io.reactivex.internal.functions.Functions.createArrayList:(I)Ljava/util/concurrent/Callable;
            invokestatic io.reactivex.internal.util.ListAddBiConsumer.instance:()Lio/reactivex/functions/BiFunction;
            invokevirtual io.reactivex.parallel.ParallelFlowable.reduce:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/BiFunction;)Lio/reactivex/parallel/ParallelFlowable;
            astore 4 /* railReduced */
        start local 4 // io.reactivex.parallel.ParallelFlowable railReduced
         4: .line 509
            aload 4 /* railReduced */
            new io.reactivex.internal.util.SorterFunction
            dup
            aload 1 /* comparator */
            invokespecial io.reactivex.internal.util.SorterFunction.<init>:(Ljava/util/Comparator;)V
            invokevirtual io.reactivex.parallel.ParallelFlowable.map:(Lio/reactivex/functions/Function;)Lio/reactivex/parallel/ParallelFlowable;
            astore 5 /* railSorted */
        start local 5 // io.reactivex.parallel.ParallelFlowable railSorted
         5: .line 511
            aload 5 /* railSorted */
            new io.reactivex.internal.util.MergerBiFunction
            dup
            aload 1 /* comparator */
            invokespecial io.reactivex.internal.util.MergerBiFunction.<init>:(Ljava/util/Comparator;)V
            invokevirtual io.reactivex.parallel.ParallelFlowable.reduce:(Lio/reactivex/functions/BiFunction;)Lio/reactivex/Flowable;
            astore 6 /* merged */
        start local 6 // io.reactivex.Flowable merged
         6: .line 513
            aload 6 /* merged */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
            areturn
        end local 6 // io.reactivex.Flowable merged
        end local 5 // io.reactivex.parallel.ParallelFlowable railSorted
        end local 4 // io.reactivex.parallel.ParallelFlowable railReduced
        end local 3 // int ch
        end local 2 // int capacityHint
        end local 1 // java.util.Comparator comparator
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    7     1    comparator  Ljava/util/Comparator<-TT;>;
            0    7     2  capacityHint  I
            3    7     3            ch  I
            4    7     4   railReduced  Lio/reactivex/parallel/ParallelFlowable<Ljava/util/List<TT;>;>;
            5    7     5    railSorted  Lio/reactivex/parallel/ParallelFlowable<Ljava/util/List<TT;>;>;
            6    7     6        merged  Lio/reactivex/Flowable<Ljava/util/List<TT;>;>;
    Signature: (Ljava/util/Comparator<-TT;>;I)Lio/reactivex/Flowable<Ljava/util/List<TT;>;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
              Name  Flags
      comparator    
      capacityHint  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnNext(io.reactivex.functions.Consumer<? super T>);
    descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Consumer onNext
         0: .line 525
            aload 1 /* onNext */
            ldc "onNext is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 526
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 527
            aload 1 /* onNext */
         3: .line 528
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         4: .line 529
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         5: .line 530
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         6: .line 531
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 532
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         8: .line 533
            getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
         9: .line 534
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
        10: .line 526
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Consumer onNext
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   11     0    this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onNext  Lio/reactivex/functions/Consumer<-TT;>;
    Signature: (Lio/reactivex/functions/Consumer<-TT;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      onNext  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnNext(io.reactivex.functions.Consumer<? super T>, io.reactivex.parallel.ParallelFailureHandling);
    descriptor: (Lio/reactivex/functions/Consumer;Lio/reactivex/parallel/ParallelFailureHandling;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Consumer onNext
        start local 2 // io.reactivex.parallel.ParallelFailureHandling errorHandler
         0: .line 551
            aload 1 /* onNext */
            ldc "onNext is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 552
            aload 2 /* errorHandler */
            ldc "errorHandler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 553
            new io.reactivex.internal.operators.parallel.ParallelDoOnNextTry
            dup
            aload 0 /* this */
            aload 1 /* onNext */
            aload 2 /* errorHandler */
            invokespecial io.reactivex.internal.operators.parallel.ParallelDoOnNextTry.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.parallel.ParallelFailureHandling errorHandler
        end local 1 // io.reactivex.functions.Consumer onNext
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1        onNext  Lio/reactivex/functions/Consumer<-TT;>;
            0    3     2  errorHandler  Lio/reactivex/parallel/ParallelFailureHandling;
    Signature: (Lio/reactivex/functions/Consumer<-TT;>;Lio/reactivex/parallel/ParallelFailureHandling;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
              Name  Flags
      onNext        
      errorHandler  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnNext(io.reactivex.functions.Consumer<? super T>, io.reactivex.functions.BiFunction<? super java.lang.Long, ? super java.lang.Throwable, io.reactivex.parallel.ParallelFailureHandling>);
    descriptor: (Lio/reactivex/functions/Consumer;Lio/reactivex/functions/BiFunction;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Consumer onNext
        start local 2 // io.reactivex.functions.BiFunction errorHandler
         0: .line 570
            aload 1 /* onNext */
            ldc "onNext is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 571
            aload 2 /* errorHandler */
            ldc "errorHandler is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 572
            new io.reactivex.internal.operators.parallel.ParallelDoOnNextTry
            dup
            aload 0 /* this */
            aload 1 /* onNext */
            aload 2 /* errorHandler */
            invokespecial io.reactivex.internal.operators.parallel.ParallelDoOnNextTry.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/BiFunction;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.functions.BiFunction errorHandler
        end local 1 // io.reactivex.functions.Consumer onNext
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1        onNext  Lio/reactivex/functions/Consumer<-TT;>;
            0    3     2  errorHandler  Lio/reactivex/functions/BiFunction<-Ljava/lang/Long;-Ljava/lang/Throwable;Lio/reactivex/parallel/ParallelFailureHandling;>;
    Signature: (Lio/reactivex/functions/Consumer<-TT;>;Lio/reactivex/functions/BiFunction<-Ljava/lang/Long;-Ljava/lang/Throwable;Lio/reactivex/parallel/ParallelFailureHandling;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
              Name  Flags
      onNext        
      errorHandler  

  public final io.reactivex.parallel.ParallelFlowable<T> doAfterNext(io.reactivex.functions.Consumer<? super T>);
    descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Consumer onAfterNext
         0: .line 585
            aload 1 /* onAfterNext */
            ldc "onAfterNext is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 586
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 587
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 588
            aload 1 /* onAfterNext */
         4: .line 589
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         5: .line 590
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         6: .line 591
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 592
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         8: .line 593
            getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
         9: .line 594
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
        10: .line 586
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Consumer onAfterNext
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   11     0         this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onAfterNext  Lio/reactivex/functions/Consumer<-TT;>;
    Signature: (Lio/reactivex/functions/Consumer<-TT;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
             Name  Flags
      onAfterNext  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnError(io.reactivex.functions.Consumer<java.lang.Throwable>);
    descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Consumer onError
         0: .line 607
            aload 1 /* onError */
            ldc "onError is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 608
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 609
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 610
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         4: .line 611
            aload 1 /* onError */
         5: .line 612
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         6: .line 613
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 614
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         8: .line 615
            getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
         9: .line 616
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
        10: .line 608
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Consumer onError
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   11     0     this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onError  Lio/reactivex/functions/Consumer<Ljava/lang/Throwable;>;
    Signature: (Lio/reactivex/functions/Consumer<Ljava/lang/Throwable;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
         Name  Flags
      onError  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnComplete(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Action onComplete
         0: .line 629
            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 630
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 631
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 632
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         4: .line 633
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         5: .line 634
            aload 1 /* onComplete */
         6: .line 635
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 636
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         8: .line 637
            getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
         9: .line 638
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
        10: .line 630
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Action onComplete
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   11     0        this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onComplete  Lio/reactivex/functions/Action;
    Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      onComplete  

  public final io.reactivex.parallel.ParallelFlowable<T> doAfterTerminated(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Action onAfterTerminate
         0: .line 651
            aload 1 /* onAfterTerminate */
            ldc "onAfterTerminate is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 652
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 653
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 654
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         4: .line 655
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         5: .line 656
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         6: .line 657
            aload 1 /* onAfterTerminate */
         7: .line 658
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         8: .line 659
            getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
         9: .line 660
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
        10: .line 652
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Action onAfterTerminate
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   11     0              this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onAfterTerminate  Lio/reactivex/functions/Action;
    Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                  Name  Flags
      onAfterTerminate  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnSubscribe(io.reactivex.functions.Consumer<? super org.reactivestreams.Subscription>);
    descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Consumer onSubscribe
         0: .line 673
            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 674
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 675
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 676
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         4: .line 677
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         5: .line 678
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         6: .line 679
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 680
            aload 1 /* onSubscribe */
         8: .line 681
            getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
         9: .line 682
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
        10: .line 674
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Consumer onSubscribe
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   11     0         this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onSubscribe  Lio/reactivex/functions/Consumer<-Lorg/reactivestreams/Subscription;>;
    Signature: (Lio/reactivex/functions/Consumer<-Lorg/reactivestreams/Subscription;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
             Name  Flags
      onSubscribe  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnRequest(io.reactivex.functions.LongConsumer);
    descriptor: (Lio/reactivex/functions/LongConsumer;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.LongConsumer onRequest
         0: .line 695
            aload 1 /* onRequest */
            ldc "onRequest is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 696
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 697
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 698
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         4: .line 699
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         5: .line 700
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         6: .line 701
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 702
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         8: .line 703
            aload 1 /* onRequest */
         9: .line 704
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
        10: .line 696
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.LongConsumer onRequest
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   11     0       this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onRequest  Lio/reactivex/functions/LongConsumer;
    Signature: (Lio/reactivex/functions/LongConsumer;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      onRequest  

  public final io.reactivex.parallel.ParallelFlowable<T> doOnCancel(io.reactivex.functions.Action);
    descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=11, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Action onCancel
         0: .line 717
            aload 1 /* onCancel */
            ldc "onCancel is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 718
            new io.reactivex.internal.operators.parallel.ParallelPeek
            dup
            aload 0 /* this */
         2: .line 719
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         3: .line 720
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         4: .line 721
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         5: .line 722
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         6: .line 723
            getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
         7: .line 724
            invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
         8: .line 725
            getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
         9: .line 726
            aload 1 /* onCancel */
        10: .line 718
            invokespecial io.reactivex.internal.operators.parallel.ParallelPeek.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/LongConsumer;Lio/reactivex/functions/Action;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Action onCancel
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   11     0      this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0   11     1  onCancel  Lio/reactivex/functions/Action;
    Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      onCancel  

  public final <C> io.reactivex.parallel.ParallelFlowable<C> collect(java.util.concurrent.Callable<? extends C>, io.reactivex.functions.BiConsumer<? super C, ? super T>);
    descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/BiConsumer;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // java.util.concurrent.Callable collectionSupplier
        start local 2 // io.reactivex.functions.BiConsumer collector
         0: .line 742
            aload 1 /* collectionSupplier */
            ldc "collectionSupplier is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 743
            aload 2 /* collector */
            ldc "collector is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 744
            new io.reactivex.internal.operators.parallel.ParallelCollect
            dup
            aload 0 /* this */
            aload 1 /* collectionSupplier */
            aload 2 /* collector */
            invokespecial io.reactivex.internal.operators.parallel.ParallelCollect.<init>:(Lio/reactivex/parallel/ParallelFlowable;Ljava/util/concurrent/Callable;Lio/reactivex/functions/BiConsumer;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // io.reactivex.functions.BiConsumer collector
        end local 1 // java.util.concurrent.Callable collectionSupplier
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    3     0                this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1  collectionSupplier  Ljava/util/concurrent/Callable<+TC;>;
            0    3     2           collector  Lio/reactivex/functions/BiConsumer<-TC;-TT;>;
    Signature: <C:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+TC;>;Lio/reactivex/functions/BiConsumer<-TC;-TT;>;)Lio/reactivex/parallel/ParallelFlowable<TC;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
        io.reactivex.annotations.NonNull()
    MethodParameters:
                    Name  Flags
      collectionSupplier  
      collector           

  public static <T> io.reactivex.parallel.ParallelFlowable<T> fromArray(org.reactivestreams.Publisher<T>[]);
    descriptor: ([Lorg/reactivestreams/Publisher;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher[] publishers
         0: .line 758
            aload 0 /* publishers */
            arraylength
            ifne 2
         1: .line 759
            new java.lang.IllegalArgumentException
            dup
            ldc "Zero publishers not supported"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 761
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.parallel.ParallelFromArray
            dup
            aload 0 /* publishers */
            invokespecial io.reactivex.internal.operators.parallel.ParallelFromArray.<init>:([Lorg/reactivestreams/Publisher;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 0 // org.reactivestreams.Publisher[] publishers
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0  publishers  [Lorg/reactivestreams/Publisher;
    Signature: <T:Ljava/lang/Object;>([Lorg/reactivestreams/Publisher<TT;>;)Lio/reactivex/parallel/ParallelFlowable<TT;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
            Name  Flags
      publishers  

  public final <U> U to(io.reactivex.functions.Function<? super io.reactivex.parallel.ParallelFlowable<T>, 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.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function converter
         0: .line 776
            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 777
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* ex */
        start local 2 // java.lang.Throwable ex
         3: .line 778
            aload 2 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         4: .line 779
            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.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0       this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    5     1  converter  Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable<TT;>;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/parallel/ParallelFlowable<TT;>;TU;>;)TU;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      converter  

  public final <U> io.reactivex.parallel.ParallelFlowable<U> compose(io.reactivex.parallel.ParallelTransformer<T, U>);
    descriptor: (Lio/reactivex/parallel/ParallelTransformer;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.parallel.ParallelTransformer composer
         0: .line 794
            aload 1 /* composer */
            ldc "composer is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.parallel.ParallelTransformer
            aload 0 /* this */
            invokeinterface io.reactivex.parallel.ParallelTransformer.apply:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.parallel.ParallelTransformer composer
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    1     0      this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1  composer  Lio/reactivex/parallel/ParallelTransformer<TT;TU;>;
    Signature: <U:Ljava/lang/Object;>(Lio/reactivex/parallel/ParallelTransformer<TT;TU;>;)Lio/reactivex/parallel/ParallelFlowable<TU;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      composer  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> flatMap(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>);
    descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
         0: .line 809
            aload 0 /* this */
            aload 1 /* mapper */
            iconst_0
            ldc 2147483647
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokevirtual io.reactivex.parallel.ParallelFlowable.flatMap:(Lio/reactivex/functions/Function;ZII)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0    this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1  mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      mapper  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> flatMap(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean);
    descriptor: (Lio/reactivex/functions/Function;Z)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // boolean delayError
         0: .line 826
            aload 0 /* this */
            aload 1 /* mapper */
            iload 2 /* delayError */
            ldc 2147483647
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokevirtual io.reactivex.parallel.ParallelFlowable.flatMap:(Lio/reactivex/functions/Function;ZII)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // boolean delayError
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1      mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0    1     2  delayError  Z
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;Z)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
            Name  Flags
      mapper      
      delayError  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> flatMap(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean, int);
    descriptor: (Lio/reactivex/functions/Function;ZI)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // boolean delayError
        start local 3 // int maxConcurrency
         0: .line 845
            aload 0 /* this */
            aload 1 /* mapper */
            iload 2 /* delayError */
            iload 3 /* maxConcurrency */
            invokestatic io.reactivex.Flowable.bufferSize:()I
            invokevirtual io.reactivex.parallel.ParallelFlowable.flatMap:(Lio/reactivex/functions/Function;ZII)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 3 // int maxConcurrency
        end local 2 // boolean delayError
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    1     0            this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1          mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0    1     2      delayError  Z
            0    1     3  maxConcurrency  I
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ZI)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
    MethodParameters:
                Name  Flags
      mapper          
      delayError      
      maxConcurrency  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> flatMap(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean, int, int);
    descriptor: (Lio/reactivex/functions/Function;ZII)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=7, locals=5, args_size=5
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // boolean delayError
        start local 3 // int maxConcurrency
        start local 4 // int prefetch
         0: .line 865
            aload 1 /* mapper */
            ldc "mapper is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 866
            iload 3 /* maxConcurrency */
            ldc "maxConcurrency"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 867
            iload 4 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         3: .line 868
            new io.reactivex.internal.operators.parallel.ParallelFlatMap
            dup
            aload 0 /* this */
            aload 1 /* mapper */
            iload 2 /* delayError */
            iload 3 /* maxConcurrency */
            iload 4 /* prefetch */
            invokespecial io.reactivex.internal.operators.parallel.ParallelFlatMap.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Function;ZII)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 4 // int prefetch
        end local 3 // int maxConcurrency
        end local 2 // boolean delayError
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    4     0            this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    4     1          mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0    4     2      delayError  Z
            0    4     3  maxConcurrency  I
            0    4     4        prefetch  I
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ZII)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
      3:
    MethodParameters:
                Name  Flags
      mapper          
      delayError      
      maxConcurrency  
      prefetch        

  public final <R> io.reactivex.parallel.ParallelFlowable<R> concatMap(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>);
    descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
         0: .line 884
            aload 0 /* this */
            aload 1 /* mapper */
            iconst_2
            invokevirtual io.reactivex.parallel.ParallelFlowable.concatMap:(Lio/reactivex/functions/Function;I)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0    this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1  mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
        Name  Flags
      mapper  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> concatMap(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, int);
    descriptor: (Lio/reactivex/functions/Function;I)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // int prefetch
         0: .line 902
            aload 1 /* mapper */
            ldc "mapper is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 903
            iload 2 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 904
            new io.reactivex.internal.operators.parallel.ParallelConcatMap
            dup
            aload 0 /* this */
            aload 1 /* mapper */
            iload 2 /* prefetch */
            getstatic io.reactivex.internal.util.ErrorMode.IMMEDIATE:Lio/reactivex/internal/util/ErrorMode;
            invokespecial io.reactivex.internal.operators.parallel.ParallelConcatMap.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // int prefetch
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    3     1    mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0    3     2  prefetch  I
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;I)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
          Name  Flags
      mapper    
      prefetch  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> concatMapDelayError(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean);
    descriptor: (Lio/reactivex/functions/Function;Z)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // boolean tillTheEnd
         0: .line 923
            aload 0 /* this */
            aload 1 /* mapper */
            iconst_2
            iload 2 /* tillTheEnd */
            invokevirtual io.reactivex.parallel.ParallelFlowable.concatMapDelayError:(Lio/reactivex/functions/Function;IZ)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 2 // boolean tillTheEnd
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    1     1      mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0    1     2  tillTheEnd  Z
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;Z)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
    MethodParameters:
            Name  Flags
      mapper      
      tillTheEnd  

  public final <R> io.reactivex.parallel.ParallelFlowable<R> concatMapDelayError(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, int, boolean);
    descriptor: (Lio/reactivex/functions/Function;IZ)Lio/reactivex/parallel/ParallelFlowable;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=6, locals=4, args_size=4
        start local 0 // io.reactivex.parallel.ParallelFlowable this
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // int prefetch
        start local 3 // boolean tillTheEnd
         0: .line 942
            aload 1 /* mapper */
            ldc "mapper is null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 943
            iload 2 /* prefetch */
            ldc "prefetch"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         2: .line 944
            new io.reactivex.internal.operators.parallel.ParallelConcatMap
            dup
         3: .line 945
            aload 0 /* this */
            aload 1 /* mapper */
            iload 2 /* prefetch */
            iload 3 /* tillTheEnd */
            ifeq 4
            getstatic io.reactivex.internal.util.ErrorMode.END:Lio/reactivex/internal/util/ErrorMode;
            goto 5
      StackMap locals: io.reactivex.parallel.ParallelFlowable io.reactivex.functions.Function int int
      StackMap stack: new 2 new 2 io.reactivex.parallel.ParallelFlowable io.reactivex.functions.Function int
         4: getstatic io.reactivex.internal.util.ErrorMode.BOUNDARY:Lio/reactivex/internal/util/ErrorMode;
         5: .line 944
      StackMap locals: io.reactivex.parallel.ParallelFlowable io.reactivex.functions.Function int int
      StackMap stack: new 2 new 2 io.reactivex.parallel.ParallelFlowable io.reactivex.functions.Function int io.reactivex.internal.util.ErrorMode
            invokespecial io.reactivex.internal.operators.parallel.ParallelConcatMap.<init>:(Lio/reactivex/parallel/ParallelFlowable;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V
            invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
            areturn
        end local 3 // boolean tillTheEnd
        end local 2 // int prefetch
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // io.reactivex.parallel.ParallelFlowable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Lio/reactivex/parallel/ParallelFlowable<TT;>;
            0    6     1      mapper  Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0    6     2    prefetch  I
            0    6     3  tillTheEnd  Z
    Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;IZ)Lio/reactivex/parallel/ParallelFlowable<TR;>;
    RuntimeVisibleAnnotations: 
      io.reactivex.annotations.CheckReturnValue()
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
    MethodParameters:
            Name  Flags
      mapper      
      prefetch    
      tillTheEnd  
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "ParallelFlowable.java"