public abstract class reactor.core.publisher.ParallelFlux<T> implements reactor.core.CorePublisher<T>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: reactor.core.publisher.ParallelFlux
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 Lreactor/core/publisher/ParallelFlux<TT;>;
public static <T> reactor.core.publisher.ParallelFlux<T> from(org.reactivestreams.Publisher<? extends T>);
descriptor: (Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getstatic reactor.core.scheduler.Schedulers.DEFAULT_POOL_SIZE:I
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
1: invokestatic reactor.util.concurrent.Queues.small:()Ljava/util/function/Supplier;
2: invokestatic reactor.core.publisher.ParallelFlux.from:(Lorg/reactivestreams/Publisher;IILjava/util/function/Supplier;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source Lorg/reactivestreams/Publisher<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
source
public static <T> reactor.core.publisher.ParallelFlux<T> from(org.reactivestreams.Publisher<? extends T>, int);
descriptor: (Lorg/reactivestreams/Publisher;I)Lreactor/core/publisher/ParallelFlux;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
1: iload 1
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
2: invokestatic reactor.util.concurrent.Queues.small:()Ljava/util/function/Supplier;
3: invokestatic reactor.core.publisher.ParallelFlux.from:(Lorg/reactivestreams/Publisher;IILjava/util/function/Supplier;)Lreactor/core/publisher/ParallelFlux;
areturn
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
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;I)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
source
parallelism
public static <T> reactor.core.publisher.ParallelFlux<T> from(org.reactivestreams.Publisher<? extends T>, int, int, java.util.function.Supplier<java.util.Queue<T>>);
descriptor: (Lorg/reactivestreams/Publisher;IILjava/util/function/Supplier;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
ldc "queueSupplier"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
ldc "source"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new reactor.core.publisher.ParallelSource
dup
aload 0
3: iload 1
4: iload 2
aload 3
5: invokespecial reactor.core.publisher.ParallelSource.<init>:(Lorg/reactivestreams/Publisher;IILjava/util/function/Supplier;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 source Lorg/reactivestreams/Publisher<+TT;>;
0 6 1 parallelism I
0 6 2 prefetch I
0 6 3 queueSupplier Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;IILjava/util/function/Supplier<Ljava/util/Queue<TT;>;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
source
parallelism
prefetch
queueSupplier
public static <T> reactor.core.publisher.ParallelFlux<T> from(org.reactivestreams.Publisher<T>[]);
descriptor: ([Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=3, locals=1, args_size=1
start local 0 0: new reactor.core.publisher.ParallelArraySource
dup
aload 0
invokespecial reactor.core.publisher.ParallelArraySource.<init>:([Lorg/reactivestreams/Publisher;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 publishers [Lorg/reactivestreams/Publisher;
Signature: <T:Ljava/lang/Object;>([Lorg/reactivestreams/Publisher<TT;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
RuntimeVisibleAnnotations:
java.lang.SafeVarargs()
MethodParameters:
Name Flags
publishers
public final <U> U as(java.util.function.Function<? super reactor.core.publisher.ParallelFlux<T>, U>);
descriptor: (Ljava/util/function/Function;)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
aload 0
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 converter Ljava/util/function/Function<-Lreactor/core/publisher/ParallelFlux<TT;>;TU;>;
Signature: <U:Ljava/lang/Object;>(Ljava/util/function/Function<-Lreactor/core/publisher/ParallelFlux<TT;>;TU;>;)TU;
MethodParameters:
Name Flags
converter
public final reactor.core.publisher.ParallelFlux<T> checkpoint();
descriptor: ()Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=1
start local 0 0: new reactor.core.publisher.FluxOnAssembly$AssemblySnapshot
dup
aconst_null
getstatic reactor.core.publisher.Traces.callSiteSupplierFactory:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.function.Supplier
invokespecial reactor.core.publisher.FluxOnAssembly$AssemblySnapshot.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;)V
astore 1
start local 1 1: new reactor.core.publisher.ParallelFluxOnAssembly
dup
aload 0
aload 1
invokespecial reactor.core.publisher.ParallelFluxOnAssembly.<init>:(Lreactor/core/publisher/ParallelFlux;Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
1 2 1 stacktrace Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;
Signature: ()Lreactor/core/publisher/ParallelFlux<TT;>;
public final reactor.core.publisher.ParallelFlux<T> checkpoint(java.lang.String);
descriptor: (Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: new reactor.core.publisher.ParallelFluxOnAssembly
dup
aload 0
new reactor.core.publisher.FluxOnAssembly$AssemblyLightSnapshot
dup
aload 1
invokespecial reactor.core.publisher.FluxOnAssembly$AssemblyLightSnapshot.<init>:(Ljava/lang/String;)V
invokespecial reactor.core.publisher.ParallelFluxOnAssembly.<init>:(Lreactor/core/publisher/ParallelFlux;Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 description Ljava/lang/String;
Signature: (Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
description
public final reactor.core.publisher.ParallelFlux<T> checkpoint(java.lang.String, boolean);
descriptor: (Ljava/lang/String;Z)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: iload 2
ifne 3
1: new reactor.core.publisher.FluxOnAssembly$AssemblyLightSnapshot
dup
aload 1
invokespecial reactor.core.publisher.FluxOnAssembly$AssemblyLightSnapshot.<init>:(Ljava/lang/String;)V
astore 3
start local 3 2: goto 4
end local 3 3: StackMap locals:
StackMap stack:
new reactor.core.publisher.FluxOnAssembly$AssemblySnapshot
dup
aload 1
getstatic reactor.core.publisher.Traces.callSiteSupplierFactory:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.function.Supplier
invokespecial reactor.core.publisher.FluxOnAssembly$AssemblySnapshot.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;)V
astore 3
start local 3 4: StackMap locals: reactor.core.publisher.FluxOnAssembly$AssemblySnapshot
StackMap stack:
new reactor.core.publisher.ParallelFluxOnAssembly
dup
aload 0
aload 3
invokespecial reactor.core.publisher.ParallelFluxOnAssembly.<init>:(Lreactor/core/publisher/ParallelFlux;Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 5 1 description Ljava/lang/String;
0 5 2 forceStackTrace Z
2 3 3 stacktrace Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;
4 5 3 stacktrace Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;
Signature: (Ljava/lang/String;Z)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
description
forceStackTrace
public final <C> reactor.core.publisher.ParallelFlux<C> collect(java.util.function.Supplier<? extends C>, java.util.function.BiConsumer<? super C, ? super T>);
descriptor: (Ljava/util/function/Supplier;Ljava/util/function/BiConsumer;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new reactor.core.publisher.ParallelCollect
dup
aload 0
aload 1
aload 2
invokespecial reactor.core.publisher.ParallelCollect.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Supplier;Ljava/util/function/BiConsumer;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 collectionSupplier Ljava/util/function/Supplier<+TC;>;
0 1 2 collector Ljava/util/function/BiConsumer<-TC;-TT;>;
Signature: <C:Ljava/lang/Object;>(Ljava/util/function/Supplier<+TC;>;Ljava/util/function/BiConsumer<-TC;-TT;>;)Lreactor/core/publisher/ParallelFlux<TC;>;
MethodParameters:
Name Flags
collectionSupplier
collector
public final reactor.core.publisher.Mono<java.util.List<T>> collectSortedList(java.util.Comparator<? super T>);
descriptor: (Ljava/util/Comparator;)Lreactor/core/publisher/Mono;
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 reactor.core.publisher.ParallelFlux.collectSortedList:(Ljava/util/Comparator;I)Lreactor/core/publisher/Mono;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 comparator Ljava/util/Comparator<-TT;>;
Signature: (Ljava/util/Comparator<-TT;>;)Lreactor/core/publisher/Mono<Ljava/util/List<TT;>;>;
MethodParameters:
Name Flags
comparator
public final reactor.core.publisher.Mono<java.util.List<T>> collectSortedList(java.util.Comparator<? super T>, int);
descriptor: (Ljava/util/Comparator;I)Lreactor/core/publisher/Mono;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=7, args_size=3
start local 0 start local 1 start local 2 0: iload 2
aload 0
invokevirtual reactor.core.publisher.ParallelFlux.parallelism:()I
idiv
iconst_1
iadd
istore 3
start local 3 1: aload 0
iload 3
invokedynamic get(I)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
reactor/core/publisher/ParallelFlux.lambda$0(I)Ljava/util/List; (6)
()Ljava/util/List;
invokedynamic apply()Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
reactor/core/publisher/ParallelFlux.lambda$1(Ljava/util/List;Ljava/lang/Object;)Ljava/util/List; (6)
(Ljava/util/List;Ljava/lang/Object;)Ljava/util/List;
invokevirtual reactor.core.publisher.ParallelFlux.reduce:(Ljava/util/function/Supplier;Ljava/util/function/BiFunction;)Lreactor/core/publisher/ParallelFlux;
2: astore 4
start local 4 3: aload 4
aload 1
invokedynamic apply(Ljava/util/Comparator;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
reactor/core/publisher/ParallelFlux.lambda$2(Ljava/util/Comparator;Ljava/util/List;)Ljava/util/List; (6)
(Ljava/util/List;)Ljava/util/List;
invokevirtual reactor.core.publisher.ParallelFlux.map:(Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
astore 5
start local 5 4: aload 5
aload 1
invokedynamic apply(Ljava/util/Comparator;)Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
reactor/core/publisher/ParallelFlux.lambda$3(Ljava/util/Comparator;Ljava/util/List;Ljava/util/List;)Ljava/util/List; (6)
(Ljava/util/List;Ljava/util/List;)Ljava/util/List;
invokevirtual reactor.core.publisher.ParallelFlux.reduce:(Ljava/util/function/BiFunction;)Lreactor/core/publisher/Mono;
astore 6
start local 6 5: aload 6
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 6 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 6 1 comparator Ljava/util/Comparator<-TT;>;
0 6 2 capacityHint I
1 6 3 ch I
3 6 4 railReduced Lreactor/core/publisher/ParallelFlux<Ljava/util/List<TT;>;>;
4 6 5 railSorted Lreactor/core/publisher/ParallelFlux<Ljava/util/List<TT;>;>;
5 6 6 merged Lreactor/core/publisher/Mono<Ljava/util/List<TT;>;>;
Signature: (Ljava/util/Comparator<-TT;>;I)Lreactor/core/publisher/Mono<Ljava/util/List<TT;>;>;
MethodParameters:
Name Flags
comparator
capacityHint
public final <R> reactor.core.publisher.ParallelFlux<R> concatMap(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>);
descriptor: (Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_2
getstatic reactor.core.publisher.FluxConcatMap$ErrorMode.IMMEDIATE:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
invokevirtual reactor.core.publisher.ParallelFlux.concatMap:(Ljava/util/function/Function;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
public final <R> reactor.core.publisher.ParallelFlux<R> concatMap(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, int);
descriptor: (Ljava/util/function/Function;I)Lreactor/core/publisher/ParallelFlux;
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
iload 2
getstatic reactor.core.publisher.FluxConcatMap$ErrorMode.IMMEDIATE:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
invokevirtual reactor.core.publisher.ParallelFlux.concatMap:(Ljava/util/function/Function;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 1 2 prefetch I
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;I)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
prefetch
public final <R> reactor.core.publisher.ParallelFlux<R> concatMapDelayError(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>);
descriptor: (Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_2
getstatic reactor.core.publisher.FluxConcatMap$ErrorMode.END:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
invokevirtual reactor.core.publisher.ParallelFlux.concatMap:(Ljava/util/function/Function;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
public final reactor.core.publisher.ParallelFlux<T> doAfterTerminate(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "afterTerminate"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aconst_null
aconst_null
aconst_null
aconst_null
aload 1
aconst_null
aconst_null
aconst_null
invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 afterTerminate Ljava/lang/Runnable;
Signature: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
afterTerminate
public final reactor.core.publisher.ParallelFlux<T> doOnCancel(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onCancel"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aload 1
invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 onCancel Ljava/lang/Runnable;
Signature: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
onCancel
public final reactor.core.publisher.ParallelFlux<T> doOnComplete(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onComplete"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aconst_null
aconst_null
aconst_null
aload 1
aconst_null
aconst_null
aconst_null
aconst_null
invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 onComplete Ljava/lang/Runnable;
Signature: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
onComplete
public final reactor.core.publisher.ParallelFlux<T> doOnEach(java.util.function.Consumer<? super reactor.core.publisher.Signal<T>>);
descriptor: (Ljava/util/function/Consumer;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "signalConsumer"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new reactor.core.publisher.ParallelDoOnEach
dup
2: aload 0
3: aload 1
invokedynamic accept(Ljava/util/function/Consumer;)Ljava/util/function/BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
reactor/core/publisher/ParallelFlux.lambda$4(Ljava/util/function/Consumer;Lreactor/util/context/Context;Ljava/lang/Object;)V (6)
(Lreactor/util/context/Context;Ljava/lang/Object;)V
4: aload 1
invokedynamic accept(Ljava/util/function/Consumer;)Ljava/util/function/BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
reactor/core/publisher/ParallelFlux.lambda$5(Ljava/util/function/Consumer;Lreactor/util/context/Context;Ljava/lang/Throwable;)V (6)
(Lreactor/util/context/Context;Ljava/lang/Throwable;)V
5: aload 1
invokedynamic accept(Ljava/util/function/Consumer;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
reactor/core/publisher/ParallelFlux.lambda$6(Ljava/util/function/Consumer;Lreactor/util/context/Context;)V (6)
(Lreactor/util/context/Context;)V
6: invokespecial reactor.core.publisher.ParallelDoOnEach.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/BiConsumer;Ljava/util/function/BiConsumer;Ljava/util/function/Consumer;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 7 1 signalConsumer Ljava/util/function/Consumer<-Lreactor/core/publisher/Signal<TT;>;>;
Signature: (Ljava/util/function/Consumer<-Lreactor/core/publisher/Signal<TT;>;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
signalConsumer
public final reactor.core.publisher.ParallelFlux<T> doOnError(java.util.function.Consumer<? super java.lang.Throwable>);
descriptor: (Ljava/util/function/Consumer;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onError"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aconst_null
aconst_null
aload 1
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 onError Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
Signature: (Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
onError
public final reactor.core.publisher.ParallelFlux<T> doOnSubscribe(java.util.function.Consumer<? super org.reactivestreams.Subscription>);
descriptor: (Ljava/util/function/Consumer;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onSubscribe"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aload 1
aconst_null
aconst_null
invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 onSubscribe Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;
Signature: (Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
onSubscribe
public final reactor.core.publisher.ParallelFlux<T> doOnNext(java.util.function.Consumer<? super T>);
descriptor: (Ljava/util/function/Consumer;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onNext"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 onNext Ljava/util/function/Consumer<-TT;>;
Signature: (Ljava/util/function/Consumer<-TT;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
onNext
public final reactor.core.publisher.ParallelFlux<T> doOnRequest(java.util.function.LongConsumer);
descriptor: (Ljava/util/function/LongConsumer;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onRequest"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aconst_null
aload 1
aconst_null
invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 onRequest Ljava/util/function/LongConsumer;
Signature: (Ljava/util/function/LongConsumer;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
onRequest
public final reactor.core.publisher.ParallelFlux<T> doOnTerminate(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onTerminate"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
2: aconst_null
3: aconst_null
4: aload 1
invokedynamic accept(Ljava/lang/Runnable;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
reactor/core/publisher/ParallelFlux.lambda$7(Ljava/lang/Runnable;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
5: aload 1
6: aconst_null
7: aconst_null
8: aconst_null
9: aconst_null
10: invokestatic reactor.core.publisher.ParallelFlux.doOnSignal:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 11 1 onTerminate Ljava/lang/Runnable;
Signature: (Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
onTerminate
public final reactor.core.publisher.ParallelFlux<T> filter(java.util.function.Predicate<? super T>);
descriptor: (Ljava/util/function/Predicate;)Lreactor/core/publisher/ParallelFlux;
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 java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new reactor.core.publisher.ParallelFilter
dup
aload 0
aload 1
invokespecial reactor.core.publisher.ParallelFilter.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Predicate;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 predicate Ljava/util/function/Predicate<-TT;>;
Signature: (Ljava/util/function/Predicate<-TT;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
predicate
public final <R> reactor.core.publisher.ParallelFlux<R> flatMap(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>);
descriptor: (Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
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
1: iconst_0
2: ldc 2147483647
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
3: invokevirtual reactor.core.publisher.ParallelFlux.flatMap:(Ljava/util/function/Function;ZII)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 4 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
public final <R> reactor.core.publisher.ParallelFlux<R> flatMap(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean);
descriptor: (Ljava/util/function/Function;Z)Lreactor/core/publisher/ParallelFlux;
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
1: iload 2
2: ldc 2147483647
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
3: invokevirtual reactor.core.publisher.ParallelFlux.flatMap:(Ljava/util/function/Function;ZII)Lreactor/core/publisher/ParallelFlux;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 4 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 4 2 delayError Z
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;Z)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
delayError
public final <R> reactor.core.publisher.ParallelFlux<R> flatMap(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean, int);
descriptor: (Ljava/util/function/Function;ZI)Lreactor/core/publisher/ParallelFlux;
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
1: iload 2
2: iload 3
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
3: invokevirtual reactor.core.publisher.ParallelFlux.flatMap:(Ljava/util/function/Function;ZII)Lreactor/core/publisher/ParallelFlux;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 4 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 4 2 delayError Z
0 4 3 maxConcurrency I
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ZI)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
delayError
maxConcurrency
public final <R> reactor.core.publisher.ParallelFlux<R> flatMap(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean, int, int);
descriptor: (Ljava/util/function/Function;ZII)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new reactor.core.publisher.ParallelFlatMap
dup
aload 0
1: aload 1
2: iload 2
3: iload 3
4: iload 3
invokestatic reactor.util.concurrent.Queues.get:(I)Ljava/util/function/Supplier;
5: iload 4
iload 4
invokestatic reactor.util.concurrent.Queues.get:(I)Ljava/util/function/Supplier;
6: invokespecial reactor.core.publisher.ParallelFlatMap.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Function;ZILjava/util/function/Supplier;ILjava/util/function/Supplier;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
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 Lreactor/core/publisher/ParallelFlux<TT;>;
0 7 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 7 2 delayError Z
0 7 3 maxConcurrency I
0 7 4 prefetch I
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ZII)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
delayError
maxConcurrency
prefetch
public final reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<java.lang.Integer, T>> groups();
descriptor: ()Lreactor/core/publisher/Flux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new reactor.core.publisher.ParallelGroup
dup
aload 0
invokespecial reactor.core.publisher.ParallelGroup.<init>:(Lreactor/core/publisher/ParallelFlux;)V
invokestatic reactor.core.publisher.Flux.onAssembly:(Lreactor/core/publisher/Flux;)Lreactor/core/publisher/Flux;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
Signature: ()Lreactor/core/publisher/Flux<Lreactor/core/publisher/GroupedFlux<Ljava/lang/Integer;TT;>;>;
public final reactor.core.publisher.ParallelFlux<T> hide();
descriptor: ()Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new reactor.core.publisher.ParallelFluxHide
dup
aload 0
invokespecial reactor.core.publisher.ParallelFluxHide.<init>:(Lreactor/core/publisher/ParallelFlux;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
Signature: ()Lreactor/core/publisher/ParallelFlux<TT;>;
public final reactor.core.publisher.ParallelFlux<T> log();
descriptor: ()Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
getstatic java.util.logging.Level.INFO:Ljava/util/logging/Level;
iconst_0
anewarray reactor.core.publisher.SignalType
invokevirtual reactor.core.publisher.ParallelFlux.log:(Ljava/lang/String;Ljava/util/logging/Level;[Lreactor/core/publisher/SignalType;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
Signature: ()Lreactor/core/publisher/ParallelFlux<TT;>;
public final reactor.core.publisher.ParallelFlux<T> log(java.lang.String);
descriptor: (Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic java.util.logging.Level.INFO:Ljava/util/logging/Level;
iconst_0
anewarray reactor.core.publisher.SignalType
invokevirtual reactor.core.publisher.ParallelFlux.log:(Ljava/lang/String;Ljava/util/logging/Level;[Lreactor/core/publisher/SignalType;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 category Ljava/lang/String;
Signature: (Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux<TT;>;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
category
public final reactor.core.publisher.ParallelFlux<T> log(java.lang.String, java.util.logging.Level, reactor.core.publisher.SignalType[]);
descriptor: (Ljava/lang/String;Ljava/util/logging/Level;[Lreactor/core/publisher/SignalType;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0091) ACC_PUBLIC, ACC_FINAL, ACC_VARARGS
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
aload 2
iconst_0
aload 3
invokevirtual reactor.core.publisher.ParallelFlux.log:(Ljava/lang/String;Ljava/util/logging/Level;Z[Lreactor/core/publisher/SignalType;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 category Ljava/lang/String;
0 1 2 level Ljava/util/logging/Level;
0 1 3 options [Lreactor/core/publisher/SignalType;
Signature: (Ljava/lang/String;Ljava/util/logging/Level;[Lreactor/core/publisher/SignalType;)Lreactor/core/publisher/ParallelFlux<TT;>;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
2:
MethodParameters:
Name Flags
category
level
options
public final reactor.core.publisher.ParallelFlux<T> log(java.lang.String, java.util.logging.Level, boolean, reactor.core.publisher.SignalType[]);
descriptor: (Ljava/lang/String;Ljava/util/logging/Level;Z[Lreactor/core/publisher/SignalType;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0091) ACC_PUBLIC, ACC_FINAL, ACC_VARARGS
Code:
stack=10, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new reactor.core.publisher.ParallelLog
dup
aload 0
new reactor.core.publisher.SignalLogger
dup
aload 0
aload 1
aload 2
iload 3
aload 4
invokespecial reactor.core.publisher.SignalLogger.<init>:(Lreactor/core/CorePublisher;Ljava/lang/String;Ljava/util/logging/Level;Z[Lreactor/core/publisher/SignalType;)V
invokespecial reactor.core.publisher.ParallelLog.<init>:(Lreactor/core/publisher/ParallelFlux;Lreactor/core/publisher/SignalPeek;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 category Ljava/lang/String;
0 1 2 level Ljava/util/logging/Level;
0 1 3 showOperatorLine Z
0 1 4 options [Lreactor/core/publisher/SignalType;
Signature: (Ljava/lang/String;Ljava/util/logging/Level;Z[Lreactor/core/publisher/SignalType;)Lreactor/core/publisher/ParallelFlux<TT;>;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
2:
3:
MethodParameters:
Name Flags
category
level
showOperatorLine
options
public final <U> reactor.core.publisher.ParallelFlux<U> map(java.util.function.Function<? super T, ? extends U>);
descriptor: (Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
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 java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new reactor.core.publisher.ParallelMap
dup
aload 0
aload 1
invokespecial reactor.core.publisher.ParallelMap.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Function;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 mapper Ljava/util/function/Function<-TT;+TU;>;
Signature: <U:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+TU;>;)Lreactor/core/publisher/ParallelFlux<TU;>;
MethodParameters:
Name Flags
mapper
public final reactor.core.publisher.ParallelFlux<T> name(java.lang.String);
descriptor: (Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic reactor.core.publisher.ParallelFluxName.createOrAppend:(Lreactor/core/publisher/ParallelFlux;Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 name Ljava/lang/String;
Signature: (Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
name
public final reactor.core.publisher.Flux<T> ordered(java.util.Comparator<? super T>);
descriptor: (Ljava/util/Comparator;)Lreactor/core/publisher/Flux;
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
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
invokevirtual reactor.core.publisher.ParallelFlux.ordered:(Ljava/util/Comparator;I)Lreactor/core/publisher/Flux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 comparator Ljava/util/Comparator<-TT;>;
Signature: (Ljava/util/Comparator<-TT;>;)Lreactor/core/publisher/Flux<TT;>;
MethodParameters:
Name Flags
comparator
public final reactor.core.publisher.Flux<T> ordered(java.util.Comparator<? super T>, int);
descriptor: (Ljava/util/Comparator;I)Lreactor/core/publisher/Flux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new reactor.core.publisher.ParallelMergeOrdered
dup
aload 0
iload 2
iload 2
invokestatic reactor.util.concurrent.Queues.get:(I)Ljava/util/function/Supplier;
aload 1
invokespecial reactor.core.publisher.ParallelMergeOrdered.<init>:(Lreactor/core/publisher/ParallelFlux;ILjava/util/function/Supplier;Ljava/util/Comparator;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 comparator Ljava/util/Comparator<-TT;>;
0 1 2 prefetch I
Signature: (Ljava/util/Comparator<-TT;>;I)Lreactor/core/publisher/Flux<TT;>;
MethodParameters:
Name Flags
comparator
prefetch
public abstract int parallelism();
descriptor: ()I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public final reactor.core.publisher.Mono<T> reduce(java.util.function.BiFunction<T, T, T>);
descriptor: (Ljava/util/function/BiFunction;)Lreactor/core/publisher/Mono;
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 java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new reactor.core.publisher.ParallelMergeReduce
dup
aload 0
aload 1
invokespecial reactor.core.publisher.ParallelMergeReduce.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/BiFunction;)V
invokestatic reactor.core.publisher.Mono.onAssembly:(Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 2 1 reducer Ljava/util/function/BiFunction<TT;TT;TT;>;
Signature: (Ljava/util/function/BiFunction<TT;TT;TT;>;)Lreactor/core/publisher/Mono<TT;>;
MethodParameters:
Name Flags
reducer
public final <R> reactor.core.publisher.ParallelFlux<R> reduce(java.util.function.Supplier<R>, java.util.function.BiFunction<R, ? super T, R>);
descriptor: (Ljava/util/function/Supplier;Ljava/util/function/BiFunction;)Lreactor/core/publisher/ParallelFlux;
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 java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "reducer"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new reactor.core.publisher.ParallelReduceSeed
dup
aload 0
aload 1
aload 2
invokespecial reactor.core.publisher.ParallelReduceSeed.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Supplier;Ljava/util/function/BiFunction;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 3 1 initialSupplier Ljava/util/function/Supplier<TR;>;
0 3 2 reducer Ljava/util/function/BiFunction<TR;-TT;TR;>;
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Supplier<TR;>;Ljava/util/function/BiFunction<TR;-TT;TR;>;)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
initialSupplier
reducer
public final reactor.core.publisher.ParallelFlux<T> runOn(reactor.core.scheduler.Scheduler);
descriptor: (Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ParallelFlux;
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
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
invokevirtual reactor.core.publisher.ParallelFlux.runOn:(Lreactor/core/scheduler/Scheduler;I)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 scheduler Lreactor/core/scheduler/Scheduler;
Signature: (Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
scheduler
public final reactor.core.publisher.ParallelFlux<T> runOn(reactor.core.scheduler.Scheduler, int);
descriptor: (Lreactor/core/scheduler/Scheduler;I)Lreactor/core/publisher/ParallelFlux;
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 "scheduler"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new reactor.core.publisher.ParallelRunOn
dup
aload 0
2: aload 1
3: iload 2
4: iload 2
invokestatic reactor.util.concurrent.Queues.get:(I)Ljava/util/function/Supplier;
5: invokespecial reactor.core.publisher.ParallelRunOn.<init>:(Lreactor/core/publisher/ParallelFlux;Lreactor/core/scheduler/Scheduler;ILjava/util/function/Supplier;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 6 1 scheduler Lreactor/core/scheduler/Scheduler;
0 6 2 prefetch I
Signature: (Lreactor/core/scheduler/Scheduler;I)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
scheduler
prefetch
public final reactor.core.publisher.Flux<T> sequential();
descriptor: ()Lreactor/core/publisher/Flux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
invokevirtual reactor.core.publisher.ParallelFlux.sequential:(I)Lreactor/core/publisher/Flux;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
Signature: ()Lreactor/core/publisher/Flux<TT;>;
public final reactor.core.publisher.Flux<T> sequential(int);
descriptor: (I)Lreactor/core/publisher/Flux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: new reactor.core.publisher.ParallelMergeSequential
dup
aload 0
1: iload 1
2: iload 1
invokestatic reactor.util.concurrent.Queues.get:(I)Ljava/util/function/Supplier;
3: invokespecial reactor.core.publisher.ParallelMergeSequential.<init>:(Lreactor/core/publisher/ParallelFlux;ILjava/util/function/Supplier;)V
invokestatic reactor.core.publisher.Flux.onAssembly:(Lreactor/core/publisher/Flux;)Lreactor/core/publisher/Flux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 4 1 prefetch I
Signature: (I)Lreactor/core/publisher/Flux<TT;>;
MethodParameters:
Name Flags
prefetch
public final reactor.core.publisher.Flux<T> sorted(java.util.Comparator<? super T>);
descriptor: (Ljava/util/Comparator;)Lreactor/core/publisher/Flux;
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 reactor.core.publisher.ParallelFlux.sorted:(Ljava/util/Comparator;I)Lreactor/core/publisher/Flux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 comparator Ljava/util/Comparator<-TT;>;
Signature: (Ljava/util/Comparator<-TT;>;)Lreactor/core/publisher/Flux<TT;>;
MethodParameters:
Name Flags
comparator
public final reactor.core.publisher.Flux<T> sorted(java.util.Comparator<? super T>, int);
descriptor: (Ljava/util/Comparator;I)Lreactor/core/publisher/Flux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: iload 2
aload 0
invokevirtual reactor.core.publisher.ParallelFlux.parallelism:()I
idiv
iconst_1
iadd
istore 3
start local 3 1: aload 0
iload 3
invokedynamic get(I)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
reactor/core/publisher/ParallelFlux.lambda$8(I)Ljava/util/List; (6)
()Ljava/util/List;
invokedynamic apply()Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
reactor/core/publisher/ParallelFlux.lambda$9(Ljava/util/List;Ljava/lang/Object;)Ljava/util/List; (6)
(Ljava/util/List;Ljava/lang/Object;)Ljava/util/List;
invokevirtual reactor.core.publisher.ParallelFlux.reduce:(Ljava/util/function/Supplier;Ljava/util/function/BiFunction;)Lreactor/core/publisher/ParallelFlux;
astore 4
start local 4 2: aload 4
aload 1
invokedynamic apply(Ljava/util/Comparator;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
reactor/core/publisher/ParallelFlux.lambda$10(Ljava/util/Comparator;Ljava/util/List;)Ljava/util/List; (6)
(Ljava/util/List;)Ljava/util/List;
invokevirtual reactor.core.publisher.ParallelFlux.map:(Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
astore 5
start local 5 3: new reactor.core.publisher.ParallelMergeSort
dup
aload 5
aload 1
invokespecial reactor.core.publisher.ParallelMergeSort.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/Comparator;)V
invokestatic reactor.core.publisher.Flux.onAssembly:(Lreactor/core/publisher/Flux;)Lreactor/core/publisher/Flux;
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 4 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 4 1 comparator Ljava/util/Comparator<-TT;>;
0 4 2 capacityHint I
1 4 3 ch I
2 4 4 railReduced Lreactor/core/publisher/ParallelFlux<Ljava/util/List<TT;>;>;
3 4 5 railSorted Lreactor/core/publisher/ParallelFlux<Ljava/util/List<TT;>;>;
Signature: (Ljava/util/Comparator<-TT;>;I)Lreactor/core/publisher/Flux<TT;>;
MethodParameters:
Name Flags
comparator
capacityHint
public abstract void subscribe(reactor.core.CoreSubscriber<? super T>[]);
descriptor: ([Lreactor/core/CoreSubscriber;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: ([Lreactor/core/CoreSubscriber<-TT;>;)V
MethodParameters:
Name Flags
subscribers
public final reactor.core.Disposable subscribe();
descriptor: ()Lreactor/core/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
aconst_null
aconst_null
invokevirtual reactor.core.publisher.ParallelFlux.subscribe:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;)Lreactor/core/Disposable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
public final reactor.core.Disposable subscribe(java.util.function.Consumer<? super T>);
descriptor: (Ljava/util/function/Consumer;)Lreactor/core/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
aconst_null
invokevirtual reactor.core.publisher.ParallelFlux.subscribe:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;)Lreactor/core/Disposable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 onNext Ljava/util/function/Consumer<-TT;>;
Signature: (Ljava/util/function/Consumer<-TT;>;)Lreactor/core/Disposable;
MethodParameters:
Name Flags
onNext
public final reactor.core.Disposable subscribe(java.util.function.Consumer<? super T>, java.util.function.Consumer<? super java.lang.Throwable>);
descriptor: (Ljava/util/function/Consumer;Ljava/util/function/Consumer;)Lreactor/core/Disposable;
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
aload 2
aconst_null
invokevirtual reactor.core.publisher.ParallelFlux.subscribe:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;)Lreactor/core/Disposable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 onNext Ljava/util/function/Consumer<-TT;>;
0 1 2 onError Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
Signature: (Ljava/util/function/Consumer<-TT;>;Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;)Lreactor/core/Disposable;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
MethodParameters:
Name Flags
onNext
onError
public final reactor.core.Disposable subscribe(java.util.function.Consumer<? super T>, java.util.function.Consumer<? super java.lang.Throwable>, java.lang.Runnable);
descriptor: (Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;)Lreactor/core/Disposable;
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 0
aload 1
aload 2
aload 3
aconst_null
aconst_null
invokevirtual reactor.core.publisher.ParallelFlux.subscribe:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/util/function/Consumer;Lreactor/util/context/Context;)Lreactor/core/Disposable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 onNext Ljava/util/function/Consumer<-TT;>;
0 1 2 onError Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
0 1 3 onComplete Ljava/lang/Runnable;
Signature: (Ljava/util/function/Consumer<-TT;>;Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;Ljava/lang/Runnable;)Lreactor/core/Disposable;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
reactor.util.annotation.Nullable()
2:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
onNext
onError
onComplete
public final void subscribe(reactor.core.CoreSubscriber<? super T>);
descriptor: (Lreactor/core/CoreSubscriber;)V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new reactor.core.publisher.FluxHide$SuppressFuseableSubscriber
dup
aload 1
invokestatic reactor.core.publisher.Operators.toCoreSubscriber:(Lorg/reactivestreams/Subscriber;)Lreactor/core/CoreSubscriber;
invokespecial reactor.core.publisher.FluxHide$SuppressFuseableSubscriber.<init>:(Lreactor/core/CoreSubscriber;)V
1: astore 2
start local 2 2: aload 0
invokevirtual reactor.core.publisher.ParallelFlux.sequential:()Lreactor/core/publisher/Flux;
aload 2
invokestatic reactor.core.publisher.Operators.toCoreSubscriber:(Lorg/reactivestreams/Subscriber;)Lreactor/core/CoreSubscriber;
invokevirtual reactor.core.publisher.Flux.subscribe:(Lreactor/core/CoreSubscriber;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 4 1 s Lreactor/core/CoreSubscriber<-TT;>;
2 4 2 subscriber Lreactor/core/publisher/FluxHide$SuppressFuseableSubscriber<TT;>;
Signature: (Lreactor/core/CoreSubscriber<-TT;>;)V
MethodParameters:
Name Flags
s
public final reactor.core.Disposable subscribe(java.util.function.Consumer<? super T>, java.util.function.Consumer<? super java.lang.Throwable>, java.lang.Runnable, java.util.function.Consumer<? super org.reactivestreams.Subscription>);
descriptor: (Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/util/function/Consumer;)Lreactor/core/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
aload 4
aconst_null
invokevirtual reactor.core.publisher.ParallelFlux.subscribe:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/util/function/Consumer;Lreactor/util/context/Context;)Lreactor/core/Disposable;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 onNext Ljava/util/function/Consumer<-TT;>;
0 1 2 onError Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
0 1 3 onComplete Ljava/lang/Runnable;
0 1 4 onSubscribe Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;
Signature: (Ljava/util/function/Consumer<-TT;>;Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;Ljava/lang/Runnable;Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;)Lreactor/core/Disposable;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
reactor.util.annotation.Nullable()
2:
reactor.util.annotation.Nullable()
3:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
onNext
onError
onComplete
onSubscribe
public final reactor.core.Disposable subscribe(java.util.function.Consumer<? super T>, java.util.function.Consumer<? super java.lang.Throwable>, java.lang.Runnable, reactor.util.context.Context);
descriptor: (Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Lreactor/util/context/Context;)Lreactor/core/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
aconst_null
aload 4
invokevirtual reactor.core.publisher.ParallelFlux.subscribe:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/util/function/Consumer;Lreactor/util/context/Context;)Lreactor/core/Disposable;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 onNext Ljava/util/function/Consumer<-TT;>;
0 1 2 onError Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
0 1 3 onComplete Ljava/lang/Runnable;
0 1 4 initialContext Lreactor/util/context/Context;
Signature: (Ljava/util/function/Consumer<-TT;>;Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;Ljava/lang/Runnable;Lreactor/util/context/Context;)Lreactor/core/Disposable;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
reactor.util.annotation.Nullable()
2:
reactor.util.annotation.Nullable()
3:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
onNext
onError
onComplete
initialContext
final reactor.core.Disposable subscribe(java.util.function.Consumer<? super T>, java.util.function.Consumer<? super java.lang.Throwable>, java.lang.Runnable, java.util.function.Consumer<? super org.reactivestreams.Subscription>, reactor.util.context.Context);
descriptor: (Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/util/function/Consumer;Lreactor/util/context/Context;)Lreactor/core/Disposable;
flags: (0x0010) ACC_FINAL
Code:
stack=9, locals=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokestatic reactor.core.publisher.Operators.onLastAssembly:(Lreactor/core/CorePublisher;)Lreactor/core/CorePublisher;
astore 6
start local 6 1: aload 6
instanceof reactor.core.publisher.ParallelFlux
ifeq 11
2: aload 0
invokevirtual reactor.core.publisher.ParallelFlux.parallelism:()I
anewarray reactor.core.publisher.LambdaSubscriber
astore 7
start local 7 3: iconst_0
istore 8
start local 8 4: goto 8
5: StackMap locals: reactor.core.CorePublisher reactor.core.publisher.LambdaSubscriber[] int
StackMap stack:
aload 7
iload 8
iinc 8 1
6: new reactor.core.publisher.LambdaSubscriber
dup
aload 1
aload 2
aload 3
aload 4
aload 5
invokespecial reactor.core.publisher.LambdaSubscriber.<init>:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/util/function/Consumer;Lreactor/util/context/Context;)V
7: aastore
8: StackMap locals:
StackMap stack:
iload 8
aload 7
arraylength
if_icmplt 5
9: aload 6
checkcast reactor.core.publisher.ParallelFlux
aload 7
invokevirtual reactor.core.publisher.ParallelFlux.subscribe:([Lreactor/core/CoreSubscriber;)V
10: aload 7
invokestatic reactor.core.Disposables.composite:([Lreactor/core/Disposable;)Lreactor/core/Disposable$Composite;
areturn
end local 8 end local 7 11: StackMap locals:
StackMap stack:
new reactor.core.publisher.LambdaSubscriber
dup
aload 1
aload 2
aload 3
aload 4
aload 5
invokespecial reactor.core.publisher.LambdaSubscriber.<init>:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/util/function/Consumer;Lreactor/util/context/Context;)V
12: astore 7
start local 7 13: aload 6
new reactor.core.publisher.FluxHide$SuppressFuseableSubscriber
dup
aload 7
invokespecial reactor.core.publisher.FluxHide$SuppressFuseableSubscriber.<init>:(Lreactor/core/CoreSubscriber;)V
invokestatic reactor.core.publisher.Operators.toCoreSubscriber:(Lorg/reactivestreams/Subscriber;)Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CorePublisher.subscribe:(Lreactor/core/CoreSubscriber;)V
14: aload 7
areturn
end local 7 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 15 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 15 1 onNext Ljava/util/function/Consumer<-TT;>;
0 15 2 onError Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
0 15 3 onComplete Ljava/lang/Runnable;
0 15 4 onSubscribe Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;
0 15 5 initialContext Lreactor/util/context/Context;
1 15 6 publisher Lreactor/core/CorePublisher<TT;>;
3 11 7 subscribers [Lreactor/core/publisher/LambdaSubscriber;
4 11 8 i I
13 15 7 subscriber Lreactor/core/publisher/LambdaSubscriber<-TT;>;
Signature: (Ljava/util/function/Consumer<-TT;>;Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;Ljava/lang/Runnable;Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;Lreactor/util/context/Context;)Lreactor/core/Disposable;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
reactor.util.annotation.Nullable()
2:
reactor.util.annotation.Nullable()
3:
reactor.util.annotation.Nullable()
4:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
onNext
onError
onComplete
onSubscribe
initialContext
public final void subscribe(org.reactivestreams.Subscriber<? super T>);
descriptor: (Lorg/reactivestreams/Subscriber;)V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new reactor.core.publisher.FluxHide$SuppressFuseableSubscriber
dup
aload 1
invokestatic reactor.core.publisher.Operators.toCoreSubscriber:(Lorg/reactivestreams/Subscriber;)Lreactor/core/CoreSubscriber;
invokespecial reactor.core.publisher.FluxHide$SuppressFuseableSubscriber.<init>:(Lreactor/core/CoreSubscriber;)V
1: astore 2
start local 2 2: aload 0
invokevirtual reactor.core.publisher.ParallelFlux.sequential:()Lreactor/core/publisher/Flux;
invokestatic reactor.core.publisher.Operators.onLastAssembly:(Lreactor/core/CorePublisher;)Lreactor/core/CorePublisher;
aload 2
invokestatic reactor.core.publisher.Operators.toCoreSubscriber:(Lorg/reactivestreams/Subscriber;)Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CorePublisher.subscribe:(Lreactor/core/CoreSubscriber;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 4 1 s Lorg/reactivestreams/Subscriber<-TT;>;
2 4 2 subscriber Lreactor/core/publisher/FluxHide$SuppressFuseableSubscriber<TT;>;
Signature: (Lorg/reactivestreams/Subscriber<-TT;>;)V
MethodParameters:
Name Flags
s
public final reactor.core.publisher.ParallelFlux<T> tag(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic reactor.core.publisher.ParallelFluxName.createOrAppend:(Lreactor/core/publisher/ParallelFlux;Ljava/lang/String;Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 key Ljava/lang/String;
0 1 2 value Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
key
value
public final reactor.core.publisher.Mono<java.lang.Void> then();
descriptor: ()Lreactor/core/publisher/Mono;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new reactor.core.publisher.ParallelThen
dup
aload 0
invokespecial reactor.core.publisher.ParallelThen.<init>:(Lreactor/core/publisher/ParallelFlux;)V
invokestatic reactor.core.publisher.Mono.onAssembly:(Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
Signature: ()Lreactor/core/publisher/Mono<Ljava/lang/Void;>;
public final <U> reactor.core.publisher.ParallelFlux<U> transform(java.util.function.Function<? super reactor.core.publisher.ParallelFlux<T>, reactor.core.publisher.ParallelFlux<U>>);
descriptor: (Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual reactor.core.publisher.ParallelFlux.as:(Ljava/util/function/Function;)Ljava/lang/Object;
checkcast reactor.core.publisher.ParallelFlux
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 composer Ljava/util/function/Function<-Lreactor/core/publisher/ParallelFlux<TT;>;Lreactor/core/publisher/ParallelFlux<TU;>;>;
Signature: <U:Ljava/lang/Object;>(Ljava/util/function/Function<-Lreactor/core/publisher/ParallelFlux<TT;>;Lreactor/core/publisher/ParallelFlux<TU;>;>;)Lreactor/core/publisher/ParallelFlux<TU;>;
MethodParameters:
Name Flags
composer
public final <U> reactor.core.publisher.ParallelFlux<U> transformGroups(java.util.function.Function<? super reactor.core.publisher.GroupedFlux<java.lang.Integer, T>, ? extends org.reactivestreams.Publisher<? extends U>>);
descriptor: (Ljava/util/function/Function;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual reactor.core.publisher.ParallelFlux.getPrefetch:()I
iconst_m1
if_icmple 5
1: aload 0
invokevirtual reactor.core.publisher.ParallelFlux.groups:()Lreactor/core/publisher/Flux;
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic apply(Ljava/util/function/Function;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
java/util/function/Function.apply(Ljava/lang/Object;)Ljava/lang/Object; (9 itf)
(Lreactor/core/publisher/GroupedFlux;)Lorg/reactivestreams/Publisher;
invokevirtual reactor.core.publisher.Flux.flatMap:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
2: aload 0
invokevirtual reactor.core.publisher.ParallelFlux.parallelism:()I
aload 0
invokevirtual reactor.core.publisher.ParallelFlux.getPrefetch:()I
3: invokestatic reactor.util.concurrent.Queues.small:()Ljava/util/function/Supplier;
4: invokestatic reactor.core.publisher.ParallelFlux.from:(Lorg/reactivestreams/Publisher;IILjava/util/function/Supplier;)Lreactor/core/publisher/ParallelFlux;
areturn
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.ParallelFlux.groups:()Lreactor/core/publisher/Flux;
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic apply(Ljava/util/function/Function;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
java/util/function/Function.apply(Ljava/lang/Object;)Ljava/lang/Object; (9 itf)
(Lreactor/core/publisher/GroupedFlux;)Lorg/reactivestreams/Publisher;
invokevirtual reactor.core.publisher.Flux.flatMap:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
aload 0
invokevirtual reactor.core.publisher.ParallelFlux.parallelism:()I
invokestatic reactor.core.publisher.ParallelFlux.from:(Lorg/reactivestreams/Publisher;I)Lreactor/core/publisher/ParallelFlux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 6 1 composer Ljava/util/function/Function<-Lreactor/core/publisher/GroupedFlux<Ljava/lang/Integer;TT;>;+Lorg/reactivestreams/Publisher<+TU;>;>;
Signature: <U:Ljava/lang/Object;>(Ljava/util/function/Function<-Lreactor/core/publisher/GroupedFlux<Ljava/lang/Integer;TT;>;+Lorg/reactivestreams/Publisher<+TU;>;>;)Lreactor/core/publisher/ParallelFlux<TU;>;
MethodParameters:
Name Flags
composer
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
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 reactor.core.publisher.ParallelFlux.parallelism:()I
istore 2
start local 2 1: aload 1
arraylength
iload 2
if_icmpeq 11
2: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "parallelism = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
3: 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;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
astore 3
start local 3 5: aload 1
dup
astore 7
arraylength
istore 6
iconst_0
istore 5
goto 9
StackMap locals: reactor.core.publisher.ParallelFlux org.reactivestreams.Subscriber[] int java.lang.IllegalArgumentException top int int org.reactivestreams.Subscriber[]
StackMap stack:
6: aload 7
iload 5
aaload
astore 4
start local 4 7: aload 4
aload 3
invokestatic reactor.core.publisher.Operators.error:(Lorg/reactivestreams/Subscriber;Ljava/lang/Throwable;)V
end local 4 8: iinc 5 1
StackMap locals:
StackMap stack:
9: iload 5
iload 6
if_icmplt 6
10: iconst_0
ireturn
end local 3 11: StackMap locals: reactor.core.publisher.ParallelFlux 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 12 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 12 1 subscribers [Lorg/reactivestreams/Subscriber;
1 12 2 p I
5 11 3 iae Ljava/lang/IllegalArgumentException;
7 8 4 s Lorg/reactivestreams/Subscriber<*>;
Signature: ([Lorg/reactivestreams/Subscriber<*>;)Z
MethodParameters:
Name Flags
subscribers
final <R> reactor.core.publisher.ParallelFlux<R> concatMap(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, int, reactor.core.publisher.FluxConcatMap$ErrorMode);
descriptor: (Ljava/util/function/Function;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0010) ACC_FINAL
Code:
stack=7, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new reactor.core.publisher.ParallelConcatMap
dup
aload 0
1: aload 1
2: iload 2
invokestatic reactor.util.concurrent.Queues.get:(I)Ljava/util/function/Supplier;
3: iload 2
4: aload 3
5: invokespecial reactor.core.publisher.ParallelConcatMap.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Function;Ljava/util/function/Supplier;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 6 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 6 2 prefetch I
0 6 3 errorMode Lreactor/core/publisher/FluxConcatMap$ErrorMode;
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
prefetch
errorMode
final <R> reactor.core.publisher.ParallelFlux<R> concatMapDelayError(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean, int);
descriptor: (Ljava/util/function/Function;ZI)Lreactor/core/publisher/ParallelFlux;
flags: (0x0010) ACC_FINAL
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 3
iload 2
ifeq 1
getstatic reactor.core.publisher.FluxConcatMap$ErrorMode.END:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
goto 2
StackMap locals: reactor.core.publisher.ParallelFlux java.util.function.Function int int
StackMap stack: reactor.core.publisher.ParallelFlux java.util.function.Function int
1: getstatic reactor.core.publisher.FluxConcatMap$ErrorMode.BOUNDARY:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
StackMap locals: reactor.core.publisher.ParallelFlux java.util.function.Function int int
StackMap stack: reactor.core.publisher.ParallelFlux java.util.function.Function int reactor.core.publisher.FluxConcatMap$ErrorMode
2: invokevirtual reactor.core.publisher.ParallelFlux.concatMap:(Ljava/util/function/Function;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 3 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 3 2 delayUntilEnd Z
0 3 3 prefetch I
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ZI)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
delayUntilEnd
prefetch
final <R> reactor.core.publisher.ParallelFlux<R> concatMapDelayError(java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, int);
descriptor: (Ljava/util/function/Function;I)Lreactor/core/publisher/ParallelFlux;
flags: (0x0010) ACC_FINAL
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
getstatic reactor.core.publisher.FluxConcatMap$ErrorMode.END:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
invokevirtual reactor.core.publisher.ParallelFlux.concatMap:(Ljava/util/function/Function;ILreactor/core/publisher/FluxConcatMap$ErrorMode;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
0 1 1 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 1 2 prefetch I
Signature: <R:Ljava/lang/Object;>(Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;I)Lreactor/core/publisher/ParallelFlux<TR;>;
MethodParameters:
Name Flags
mapper
prefetch
public int getPrefetch();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: iconst_m1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ParallelFlux<TT;>;
protected static <T> reactor.core.publisher.ParallelFlux<T> onAssembly(reactor.core.publisher.ParallelFlux<T>);
descriptor: (Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
flags: (0x000c) ACC_PROTECTED, ACC_STATIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: getstatic reactor.core.publisher.Hooks.onEachOperatorHook:Ljava/util/function/Function;
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
aload 0
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.ParallelFlux
astore 0
3: StackMap locals: java.util.function.Function
StackMap stack:
getstatic reactor.core.publisher.Hooks.GLOBAL_TRACE:Z
ifeq 6
4: new reactor.core.publisher.FluxOnAssembly$AssemblySnapshot
dup
aconst_null
getstatic reactor.core.publisher.Traces.callSiteSupplierFactory:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.function.Supplier
invokespecial reactor.core.publisher.FluxOnAssembly$AssemblySnapshot.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;)V
astore 2
start local 2 5: aload 0
aload 2
invokestatic reactor.core.publisher.Hooks.addAssemblyInfo:(Lorg/reactivestreams/Publisher;Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;)Lorg/reactivestreams/Publisher;
checkcast reactor.core.publisher.ParallelFlux
astore 0
end local 2 6: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 source Lreactor/core/publisher/ParallelFlux<TT;>;
1 7 1 hook Ljava/util/function/Function<Lorg/reactivestreams/Publisher;Lorg/reactivestreams/Publisher;>;
5 6 2 stacktrace Lreactor/core/publisher/FluxOnAssembly$AssemblySnapshot;
Signature: <T:Ljava/lang/Object;>(Lreactor/core/publisher/ParallelFlux<TT;>;)Lreactor/core/publisher/ParallelFlux<TT;>;
MethodParameters:
Name Flags
source
static <T> reactor.core.publisher.ParallelFlux<T> doOnSignal(reactor.core.publisher.ParallelFlux<T>, java.util.function.Consumer<? super T>, java.util.function.Consumer<? super T>, java.util.function.Consumer<? super java.lang.Throwable>, java.lang.Runnable, java.lang.Runnable, java.util.function.Consumer<? super org.reactivestreams.Subscription>, java.util.function.LongConsumer, java.lang.Runnable);
descriptor: (Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux;
flags: (0x0008) ACC_STATIC
Code:
stack=11, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: new reactor.core.publisher.ParallelPeek
dup
aload 0
1: aload 1
2: aload 2
3: aload 3
4: aload 4
5: aload 5
6: aload 6
7: aload 7
8: aload 8
9: invokespecial reactor.core.publisher.ParallelPeek.<init>:(Lreactor/core/publisher/ParallelFlux;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)V
invokestatic reactor.core.publisher.ParallelFlux.onAssembly:(Lreactor/core/publisher/ParallelFlux;)Lreactor/core/publisher/ParallelFlux;
areturn
end local 8 end local 7 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 10 0 source Lreactor/core/publisher/ParallelFlux<TT;>;
0 10 1 onNext Ljava/util/function/Consumer<-TT;>;
0 10 2 onAfterNext Ljava/util/function/Consumer<-TT;>;
0 10 3 onError Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
0 10 4 onComplete Ljava/lang/Runnable;
0 10 5 onAfterTerminate Ljava/lang/Runnable;
0 10 6 onSubscribe Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;
0 10 7 onRequest Ljava/util/function/LongConsumer;
0 10 8 onCancel Ljava/lang/Runnable;
Signature: <T:Ljava/lang/Object;>(Lreactor/core/publisher/ParallelFlux<TT;>;Ljava/util/function/Consumer<-TT;>;Ljava/util/function/Consumer<-TT;>;Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;Ljava/lang/Runnable;Ljava/lang/Runnable;Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;Ljava/util/function/LongConsumer;Ljava/lang/Runnable;)Lreactor/core/publisher/ParallelFlux<TT;>;
RuntimeVisibleParameterAnnotations:
0:
1:
reactor.util.annotation.Nullable()
2:
reactor.util.annotation.Nullable()
3:
reactor.util.annotation.Nullable()
4:
reactor.util.annotation.Nullable()
5:
reactor.util.annotation.Nullable()
6:
reactor.util.annotation.Nullable()
7:
reactor.util.annotation.Nullable()
8:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
source
onNext
onAfterNext
onError
onComplete
onAfterTerminate
onSubscribe
onRequest
onCancel
static final <T> java.util.List<T> sortedMerger(java.util.List<T>, java.util.List<T>, java.util.Comparator<? super T>);
descriptor: (Ljava/util/List;Ljava/util/List;Ljava/util/Comparator;)Ljava/util/List;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Code:
stack=3, locals=9, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokeinterface java.util.List.size:()I
aload 1
invokeinterface java.util.List.size:()I
iadd
istore 3
start local 3 1: iload 3
ifne 3
2: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
areturn
3: StackMap locals: int
StackMap stack:
new java.util.ArrayList
dup
iload 3
invokespecial java.util.ArrayList.<init>:(I)V
astore 4
start local 4 4: aload 0
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
start local 5 5: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 6
start local 6 6: aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 7
aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
goto 8
StackMap locals: java.util.List java.util.Iterator java.util.Iterator
StackMap stack:
7: aconst_null
StackMap locals:
StackMap stack: java.lang.Object
8: astore 7
start local 7 9: aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 10
aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
goto 11
StackMap locals: java.lang.Object
StackMap stack:
10: aconst_null
StackMap locals:
StackMap stack: java.lang.Object
11: astore 8
start local 8 12: goto 23
13: StackMap locals: java.lang.Object
StackMap stack:
aload 2
aload 7
aload 8
invokeinterface java.util.Comparator.compare:(Ljava/lang/Object;Ljava/lang/Object;)I
ifge 19
14: aload 4
aload 7
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
15: aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 16
aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
goto 17
StackMap locals:
StackMap stack:
16: aconst_null
StackMap locals:
StackMap stack: java.lang.Object
17: astore 7
18: goto 23
19: StackMap locals:
StackMap stack:
aload 4
aload 8
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
20: aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 21
aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
goto 22
StackMap locals:
StackMap stack:
21: aconst_null
StackMap locals:
StackMap stack: java.lang.Object
22: astore 8
23: StackMap locals:
StackMap stack:
aload 7
ifnull 24
aload 8
ifnonnull 13
24: StackMap locals:
StackMap stack:
aload 7
ifnull 30
25: aload 4
aload 7
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
26: goto 28
27: StackMap locals:
StackMap stack:
aload 4
aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
28: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 27
29: goto 35
30: StackMap locals:
StackMap stack:
aload 8
ifnull 35
31: aload 4
aload 8
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
32: goto 34
33: StackMap locals:
StackMap stack:
aload 4
aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
34: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 33
35: StackMap locals:
StackMap stack:
aload 4
areturn
end local 8 end local 7 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 36 0 a Ljava/util/List<TT;>;
0 36 1 b Ljava/util/List<TT;>;
0 36 2 comparator Ljava/util/Comparator<-TT;>;
1 36 3 n I
4 36 4 both Ljava/util/List<TT;>;
5 36 5 at Ljava/util/Iterator<TT;>;
6 36 6 bt Ljava/util/Iterator<TT;>;
9 36 7 s1 TT;
12 36 8 s2 TT;
Signature: <T:Ljava/lang/Object;>(Ljava/util/List<TT;>;Ljava/util/List<TT;>;Ljava/util/Comparator<-TT;>;)Ljava/util/List<TT;>;
MethodParameters:
Name Flags
a
b
comparator
private static java.util.List lambda$0(int);
descriptor: (I)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
0: new java.util.ArrayList
dup
iload 0
invokespecial java.util.ArrayList.<init>:(I)V
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.util.List lambda$1(java.util.List, java.lang.Object);
descriptor: (Ljava/util/List;Ljava/lang/Object;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 a Ljava/util/List<TT;>;
0 2 1 b TT;
private static java.util.List lambda$2(java.util.Comparator, java.util.List);
descriptor: (Ljava/util/Comparator;Ljava/util/List;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface java.util.List.sort:(Ljava/util/Comparator;)V
1: aload 1
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 list Ljava/util/List<TT;>;
private static java.util.List lambda$3(java.util.Comparator, java.util.List, java.util.List);
descriptor: (Ljava/util/Comparator;Ljava/util/List;Ljava/util/List;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 1 start local 2 0: aload 1
aload 2
aload 0
invokestatic reactor.core.publisher.ParallelFlux.sortedMerger:(Ljava/util/List;Ljava/util/List;Ljava/util/Comparator;)Ljava/util/List;
areturn
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 a Ljava/util/List<TT;>;
0 1 2 b Ljava/util/List<TT;>;
private static void lambda$4(java.util.function.Consumer, reactor.util.context.Context, java.lang.Object);
descriptor: (Ljava/util/function/Consumer;Lreactor/util/context/Context;Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 1 start local 2 0: aload 0
aload 2
aload 1
invokestatic reactor.core.publisher.Signal.next:(Ljava/lang/Object;Lreactor/util/context/Context;)Lreactor/core/publisher/Signal;
invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 ctx Lreactor/util/context/Context;
0 1 2 v TT;
private static void lambda$5(java.util.function.Consumer, reactor.util.context.Context, java.lang.Throwable);
descriptor: (Ljava/util/function/Consumer;Lreactor/util/context/Context;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 1 start local 2 0: aload 0
aload 2
aload 1
invokestatic reactor.core.publisher.Signal.error:(Ljava/lang/Throwable;Lreactor/util/context/Context;)Lreactor/core/publisher/Signal;
invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 ctx Lreactor/util/context/Context;
0 1 2 e Ljava/lang/Throwable;
private static void lambda$6(java.util.function.Consumer, reactor.util.context.Context);
descriptor: (Ljava/util/function/Consumer;Lreactor/util/context/Context;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokestatic reactor.core.publisher.Signal.complete:(Lreactor/util/context/Context;)Lreactor/core/publisher/Signal;
invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 ctx Lreactor/util/context/Context;
private static void lambda$7(java.lang.Runnable, java.lang.Throwable);
descriptor: (Ljava/lang/Runnable;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface java.lang.Runnable.run:()V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 e Ljava/lang/Throwable;
private static java.util.List lambda$8(int);
descriptor: (I)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
0: new java.util.ArrayList
dup
iload 0
invokespecial java.util.ArrayList.<init>:(I)V
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.util.List lambda$9(java.util.List, java.lang.Object);
descriptor: (Ljava/util/List;Ljava/lang/Object;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 a Ljava/util/List<TT;>;
0 2 1 b TT;
private static java.util.List lambda$10(java.util.Comparator, java.util.List);
descriptor: (Ljava/util/Comparator;Ljava/util/List;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface java.util.List.sort:(Ljava/util/Comparator;)V
1: aload 1
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 list Ljava/util/List<TT;>;
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lreactor/core/CorePublisher<TT;>;
SourceFile: "ParallelFlux.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Composite = reactor.core.Disposable$Composite of reactor.core.Disposable
final ErrorMode = reactor.core.publisher.FluxConcatMap$ErrorMode of reactor.core.publisher.FluxConcatMap
final SuppressFuseableSubscriber = reactor.core.publisher.FluxHide$SuppressFuseableSubscriber of reactor.core.publisher.FluxHide
final AssemblyLightSnapshot = reactor.core.publisher.FluxOnAssembly$AssemblyLightSnapshot of reactor.core.publisher.FluxOnAssembly
AssemblySnapshot = reactor.core.publisher.FluxOnAssembly$AssemblySnapshot of reactor.core.publisher.FluxOnAssembly
ParallelFlux
lambda$0(int): List