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 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 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 start local 1 0: aload 0
invokevirtual io.reactivex.parallel.ParallelFlowable.parallelism:()I
istore 2
start local 2 1: aload 1
arraylength
iload 2
if_icmpeq 9
2: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "parallelism = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", subscribers = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
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
start local 3 3: aload 1
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
start local 4 5: aload 3
aload 4
invokestatic io.reactivex.internal.subscriptions.EmptySubscription.error:(Ljava/lang/Throwable;Lorg/reactivestreams/Subscriber;)V
end local 4 6: iinc 5 1
StackMap locals:
StackMap stack:
7: iload 5
iload 6
if_icmplt 4
8: iconst_0
ireturn
end local 3 9: StackMap locals: io.reactivex.parallel.ParallelFlowable org.reactivestreams.Subscriber[] int
StackMap stack:
iconst_1
ireturn
end local 2 end local 1 end local 0 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 0: aload 0
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 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 start local 1 0: aload 0
iload 1
invokestatic io.reactivex.Flowable.bufferSize:()I
invokestatic io.reactivex.parallel.ParallelFlowable.from:(Lorg/reactivestreams/Publisher;II)Lio/reactivex/parallel/ParallelFlowable;
areturn
end local 1 end local 0 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 start local 1 start local 2 0: aload 0
ldc "source"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 1
ldc "parallelism"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: iload 2
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
3: new io.reactivex.internal.operators.parallel.ParallelFromPublisher
dup
aload 0
iload 1
iload 2
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 end local 1 end local 0 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 start local 1 0: aload 1
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
invokeinterface io.reactivex.parallel.ParallelFlowableConverter.apply:(Lio/reactivex/parallel/ParallelFlowable;)Ljava/lang/Object;
areturn
end local 1 end local 0 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 start local 1 0: aload 1
ldc "mapper"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelMap
dup
aload 0
aload 1
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 end local 0 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 start local 1 start local 2 0: aload 1
ldc "mapper"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "errorHandler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelMapTry
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 start local 1 start local 2 0: aload 1
ldc "mapper"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "errorHandler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelMapTry
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 start local 1 0: aload 1
ldc "predicate"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelFilter
dup
aload 0
aload 1
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 end local 0 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 start local 1 start local 2 0: aload 1
ldc "predicate"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "errorHandler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelFilterTry
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 start local 1 start local 2 0: aload 1
ldc "predicate"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "errorHandler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelFilterTry
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 start local 1 0: aload 0
aload 1
invokestatic io.reactivex.Flowable.bufferSize:()I
invokevirtual io.reactivex.parallel.ParallelFlowable.runOn:(Lio/reactivex/Scheduler;I)Lio/reactivex/parallel/ParallelFlowable;
areturn
end local 1 end local 0 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 start local 1 start local 2 0: aload 1
ldc "scheduler"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 2
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: new io.reactivex.internal.operators.parallel.ParallelRunOn
dup
aload 0
aload 1
iload 2
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 end local 1 end local 0 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 start local 1 0: aload 1
ldc "reducer"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelReduceFull
dup
aload 0
aload 1
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 end local 0 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 start local 1 start local 2 0: aload 1
ldc "initialSupplier"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "reducer"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelReduce
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 0: aload 0
invokestatic io.reactivex.Flowable.bufferSize:()I
invokevirtual io.reactivex.parallel.ParallelFlowable.sequential:(I)Lio/reactivex/Flowable;
areturn
end local 0 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 start local 1 0: iload 1
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
1: new io.reactivex.internal.operators.parallel.ParallelJoin
dup
aload 0
iload 1
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 end local 0 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 0: aload 0
invokestatic io.reactivex.Flowable.bufferSize:()I
invokevirtual io.reactivex.parallel.ParallelFlowable.sequentialDelayError:(I)Lio/reactivex/Flowable;
areturn
end local 0 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 start local 1 0: iload 1
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
1: new io.reactivex.internal.operators.parallel.ParallelJoin
dup
aload 0
iload 1
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 end local 0 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 start local 1 0: aload 0
aload 1
bipush 16
invokevirtual io.reactivex.parallel.ParallelFlowable.sorted:(Ljava/util/Comparator;I)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 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 start local 1 start local 2 0: aload 1
ldc "comparator is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 2
ldc "capacityHint"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: iload 2
aload 0
invokevirtual io.reactivex.parallel.ParallelFlowable.parallelism:()I
idiv
iconst_1
iadd
istore 3
start local 3 3: aload 0
iload 3
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
start local 4 4: aload 4
new io.reactivex.internal.util.SorterFunction
dup
aload 1
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
start local 5 5: new io.reactivex.internal.operators.parallel.ParallelSortedJoin
dup
aload 5
aload 1
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 end local 4 end local 3 end local 2 end local 1 end local 0 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 start local 1 0: aload 0
aload 1
bipush 16
invokevirtual io.reactivex.parallel.ParallelFlowable.toSortedList:(Ljava/util/Comparator;I)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 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 start local 1 start local 2 0: aload 1
ldc "comparator is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 2
ldc "capacityHint"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: iload 2
aload 0
invokevirtual io.reactivex.parallel.ParallelFlowable.parallelism:()I
idiv
iconst_1
iadd
istore 3
start local 3 3: aload 0
iload 3
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
start local 4 4: aload 4
new io.reactivex.internal.util.SorterFunction
dup
aload 1
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
start local 5 5: aload 5
new io.reactivex.internal.util.MergerBiFunction
dup
aload 1
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
start local 6 6: aload 6
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 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 start local 1 0: aload 1
ldc "onNext is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: aload 1
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
8: getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
9: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
10: 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 end local 0 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 start local 1 start local 2 0: aload 1
ldc "onNext is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "errorHandler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelDoOnNextTry
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 start local 1 start local 2 0: aload 1
ldc "onNext is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "errorHandler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelDoOnNextTry
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 start local 1 0: aload 1
ldc "onAfterNext is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: aload 1
4: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
8: getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
9: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
10: 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 end local 0 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 start local 1 0: aload 1
ldc "onError is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: aload 1
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
8: getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
9: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
10: 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 end local 0 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 start local 1 0: aload 1
ldc "onComplete is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
5: aload 1
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
8: getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
9: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
10: 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 end local 0 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 start local 1 0: aload 1
ldc "onAfterTerminate is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: aload 1
7: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
8: getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
9: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
10: 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 end local 0 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 start local 1 0: aload 1
ldc "onSubscribe is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: aload 1
8: getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
9: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
10: 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 end local 0 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 start local 1 0: aload 1
ldc "onRequest is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
8: aload 1
9: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
10: 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 end local 0 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 start local 1 0: aload 1
ldc "onCancel is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.parallel.ParallelPeek
dup
aload 0
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
8: getstatic io.reactivex.internal.functions.Functions.EMPTY_LONG_CONSUMER:Lio/reactivex/functions/LongConsumer;
9: aload 1
10: 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 end local 0 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 start local 1 start local 2 0: aload 1
ldc "collectionSupplier is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "collector is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.parallel.ParallelCollect
dup
aload 0
aload 1
aload 2
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 end local 1 end local 0 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 0: aload 0
arraylength
ifne 2
1: new java.lang.IllegalArgumentException
dup
ldc "Zero publishers not supported"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.parallel.ParallelFromArray
dup
aload 0
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 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 start local 1 0: aload 1
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
invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
1: areturn
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 3: aload 2
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
4: aload 2
invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
athrow
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
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
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 end local 0 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 start local 1 0: aload 0
aload 1
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 end local 0 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 start local 1 start local 2 0: aload 0
aload 1
iload 2
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 end local 1 end local 0 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 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
iload 3
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 end local 2 end local 1 end local 0 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 start local 1 start local 2 start local 3 start local 4 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 3
ldc "maxConcurrency"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: iload 4
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
3: new io.reactivex.internal.operators.parallel.ParallelFlatMap
dup
aload 0
aload 1
iload 2
iload 3
iload 4
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 end local 3 end local 2 end local 1 end local 0 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 start local 1 0: aload 0
aload 1
iconst_2
invokevirtual io.reactivex.parallel.ParallelFlowable.concatMap:(Lio/reactivex/functions/Function;I)Lio/reactivex/parallel/ParallelFlowable;
areturn
end local 1 end local 0 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 start local 1 start local 2 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 2
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: new io.reactivex.internal.operators.parallel.ParallelConcatMap
dup
aload 0
aload 1
iload 2
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 end local 1 end local 0 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 start local 1 start local 2 0: aload 0
aload 1
iconst_2
iload 2
invokevirtual io.reactivex.parallel.ParallelFlowable.concatMapDelayError:(Lio/reactivex/functions/Function;IZ)Lio/reactivex/parallel/ParallelFlowable;
areturn
end local 2 end local 1 end local 0 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 start local 1 start local 2 start local 3 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 2
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: new io.reactivex.internal.operators.parallel.ParallelConcatMap
dup
3: aload 0
aload 1
iload 2
iload 3
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: 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 end local 2 end local 1 end local 0 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"