abstract class java.util.stream.AbstractPipeline<E_IN, E_OUT, S extends java.util.stream.BaseStream<E_OUT, S>> extends java.util.stream.PipelineHelper<E_OUT> implements java.util.stream.BaseStream<E_OUT, S>
minor version: 0
major version: 59
flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
this_class: java.util.stream.AbstractPipeline
super_class: java.util.stream.PipelineHelper
{
private static final java.lang.String MSG_STREAM_LINKED;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "stream has already been operated upon or closed"
private static final java.lang.String MSG_CONSUMED;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "source already consumed or closed"
private final java.util.stream.AbstractPipeline sourceStage;
descriptor: Ljava/util/stream/AbstractPipeline;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.stream.AbstractPipeline previousStage;
descriptor: Ljava/util/stream/AbstractPipeline;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
protected final int sourceOrOpFlags;
descriptor: I
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
private java.util.stream.AbstractPipeline nextStage;
descriptor: Ljava/util/stream/AbstractPipeline;
flags: (0x0002) ACC_PRIVATE
private int depth;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int combinedFlags;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private java.util.Spliterator<?> sourceSpliterator;
descriptor: Ljava/util/Spliterator;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Spliterator<*>;
private java.util.function.Supplier<? extends java.util.Spliterator<?>> sourceSupplier;
descriptor: Ljava/util/function/Supplier;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/function/Supplier<+Ljava/util/Spliterator<*>;>;
private boolean linkedOrConsumed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean sourceAnyStateful;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private java.lang.Runnable sourceCloseAction;
descriptor: Ljava/lang/Runnable;
flags: (0x0002) ACC_PRIVATE
private boolean parallel;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Ljava/util/stream/AbstractPipeline;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic java.util.stream.AbstractPipeline.$assertionsDisabled:Z
3: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(java.util.function.Supplier<? extends java.util.Spliterator<?>>, int, );
descriptor: (Ljava/util/function/Supplier;IZ)V
flags: (0x0000)
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.util.stream.PipelineHelper.<init>:()V
1: aload 0
aconst_null
putfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
2: aload 0
aload 1
putfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
3: aload 0
aload 0
putfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
4: aload 0
iload 2
getstatic java.util.stream.StreamOpFlag.STREAM_MASK:I
iand
putfield java.util.stream.AbstractPipeline.sourceOrOpFlags:I
5: aload 0
aload 0
getfield java.util.stream.AbstractPipeline.sourceOrOpFlags:I
iconst_1
ishl
iconst_m1
ixor
getstatic java.util.stream.StreamOpFlag.INITIAL_OPS_VALUE:I
iand
putfield java.util.stream.AbstractPipeline.combinedFlags:I
6: aload 0
iconst_0
putfield java.util.stream.AbstractPipeline.depth:I
7: aload 0
iload 3
putfield java.util.stream.AbstractPipeline.parallel:Z
8: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 9 1 source Ljava/util/function/Supplier<+Ljava/util/Spliterator<*>;>;
0 9 2 sourceFlags I
0 9 3 parallel Z
Signature: (Ljava/util/function/Supplier<+Ljava/util/Spliterator<*>;>;IZ)V
MethodParameters:
Name Flags
source
sourceFlags
parallel
void <init>(java.util.Spliterator<?>, int, );
descriptor: (Ljava/util/Spliterator;IZ)V
flags: (0x0000)
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.util.stream.PipelineHelper.<init>:()V
1: aload 0
aconst_null
putfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
2: aload 0
aload 1
putfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
3: aload 0
aload 0
putfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
4: aload 0
iload 2
getstatic java.util.stream.StreamOpFlag.STREAM_MASK:I
iand
putfield java.util.stream.AbstractPipeline.sourceOrOpFlags:I
5: aload 0
aload 0
getfield java.util.stream.AbstractPipeline.sourceOrOpFlags:I
iconst_1
ishl
iconst_m1
ixor
getstatic java.util.stream.StreamOpFlag.INITIAL_OPS_VALUE:I
iand
putfield java.util.stream.AbstractPipeline.combinedFlags:I
6: aload 0
iconst_0
putfield java.util.stream.AbstractPipeline.depth:I
7: aload 0
iload 3
putfield java.util.stream.AbstractPipeline.parallel:Z
8: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 9 1 source Ljava/util/Spliterator<*>;
0 9 2 sourceFlags I
0 9 3 parallel Z
Signature: (Ljava/util/Spliterator<*>;IZ)V
MethodParameters:
Name Flags
source
sourceFlags
parallel
void <init>(java.util.stream.AbstractPipeline<?, E_IN, ?>, );
descriptor: (Ljava/util/stream/AbstractPipeline;I)V
flags: (0x0000)
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.util.stream.PipelineHelper.<init>:()V
1: aload 1
getfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
ifeq 3
2: new java.lang.IllegalStateException
dup
ldc "stream has already been operated upon or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: java.util.stream.AbstractPipeline java.util.stream.AbstractPipeline int
StackMap stack:
aload 1
iconst_1
putfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
4: aload 1
aload 0
putfield java.util.stream.AbstractPipeline.nextStage:Ljava/util/stream/AbstractPipeline;
5: aload 0
aload 1
putfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
6: aload 0
iload 2
getstatic java.util.stream.StreamOpFlag.OP_MASK:I
iand
putfield java.util.stream.AbstractPipeline.sourceOrOpFlags:I
7: aload 0
iload 2
aload 1
getfield java.util.stream.AbstractPipeline.combinedFlags:I
invokestatic java.util.stream.StreamOpFlag.combineOpFlags:(II)I
putfield java.util.stream.AbstractPipeline.combinedFlags:I
8: aload 0
aload 1
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
putfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
9: aload 0
invokevirtual java.util.stream.AbstractPipeline.opIsStateful:()Z
ifeq 11
10: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
iconst_1
putfield java.util.stream.AbstractPipeline.sourceAnyStateful:Z
11: StackMap locals:
StackMap stack:
aload 0
aload 1
getfield java.util.stream.AbstractPipeline.depth:I
iconst_1
iadd
putfield java.util.stream.AbstractPipeline.depth:I
12: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 13 1 previousStage Ljava/util/stream/AbstractPipeline<*TE_IN;*>;
0 13 2 opFlags I
Signature: (Ljava/util/stream/AbstractPipeline<*TE_IN;*>;I)V
MethodParameters:
Name Flags
previousStage
opFlags
final <R> R evaluate(java.util.stream.TerminalOp<E_OUT, R>);
descriptor: (Ljava/util/stream/TerminalOp;)Ljava/lang/Object;
flags: (0x0010) ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic java.util.stream.AbstractPipeline.$assertionsDisabled:Z
ifne 1
aload 0
invokevirtual java.util.stream.AbstractPipeline.getOutputShape:()Ljava/util/stream/StreamShape;
aload 1
invokeinterface java.util.stream.TerminalOp.inputShape:()Ljava/util/stream/StreamShape;
if_acmpeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
ifeq 3
2: new java.lang.IllegalStateException
dup
ldc "stream has already been operated upon or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
4: aload 0
invokevirtual java.util.stream.AbstractPipeline.isParallel:()Z
ifeq 6
5: aload 1
aload 0
aload 0
aload 1
invokeinterface java.util.stream.TerminalOp.getOpFlags:()I
invokevirtual java.util.stream.AbstractPipeline.sourceSpliterator:(I)Ljava/util/Spliterator;
invokeinterface java.util.stream.TerminalOp.evaluateParallel:(Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;)Ljava/lang/Object;
goto 7
6: StackMap locals:
StackMap stack:
aload 1
aload 0
aload 0
aload 1
invokeinterface java.util.stream.TerminalOp.getOpFlags:()I
invokevirtual java.util.stream.AbstractPipeline.sourceSpliterator:(I)Ljava/util/Spliterator;
invokeinterface java.util.stream.TerminalOp.evaluateSequential:(Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;)Ljava/lang/Object;
7: StackMap locals:
StackMap stack: java.lang.Object
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 8 1 terminalOp Ljava/util/stream/TerminalOp<TE_OUT;TR;>;
Signature: <R:Ljava/lang/Object;>(Ljava/util/stream/TerminalOp<TE_OUT;TR;>;)TR;
MethodParameters:
Name Flags
terminalOp
final java.util.stream.Node<E_OUT> evaluateToArrayNode(java.util.function.IntFunction<E_OUT[]>);
descriptor: (Ljava/util/function/IntFunction;)Ljava/util/stream/Node;
flags: (0x0010) ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "stream has already been operated upon or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
3: aload 0
invokevirtual java.util.stream.AbstractPipeline.isParallel:()Z
ifeq 6
aload 0
getfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
ifnull 6
aload 0
invokevirtual java.util.stream.AbstractPipeline.opIsStateful:()Z
ifeq 6
4: aload 0
iconst_0
putfield java.util.stream.AbstractPipeline.depth:I
5: aload 0
aload 0
getfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
aload 0
getfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
iconst_0
invokevirtual java.util.stream.AbstractPipeline.sourceSpliterator:(I)Ljava/util/Spliterator;
aload 1
invokevirtual java.util.stream.AbstractPipeline.opEvaluateParallel:(Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;Ljava/util/function/IntFunction;)Ljava/util/stream/Node;
areturn
6: StackMap locals:
StackMap stack:
aload 0
aload 0
iconst_0
invokevirtual java.util.stream.AbstractPipeline.sourceSpliterator:(I)Ljava/util/Spliterator;
iconst_1
aload 1
invokevirtual java.util.stream.AbstractPipeline.evaluate:(Ljava/util/Spliterator;ZLjava/util/function/IntFunction;)Ljava/util/stream/Node;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 7 1 generator Ljava/util/function/IntFunction<[TE_OUT;>;
Signature: (Ljava/util/function/IntFunction<[TE_OUT;>;)Ljava/util/stream/Node<TE_OUT;>;
MethodParameters:
Name Flags
generator
final java.util.Spliterator<E_OUT> sourceStageSpliterator();
descriptor: ()Ljava/util/Spliterator;
flags: (0x0010) ACC_FINAL
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
if_acmpeq 2
1: new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
ifeq 4
3: new java.lang.IllegalStateException
dup
ldc "stream has already been operated upon or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
5: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
ifnull 9
6: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
astore 1
start local 1 7: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
8: aload 1
areturn
end local 1 9: StackMap locals:
StackMap stack:
aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
ifnull 13
10: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.Spliterator
astore 1
start local 1 11: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
12: aload 1
areturn
end local 1 13: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "source already consumed or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
7 9 1 s Ljava/util/Spliterator<TE_OUT;>;
11 13 1 s Ljava/util/Spliterator<TE_OUT;>;
Signature: ()Ljava/util/Spliterator<TE_OUT;>;
public final S sequential();
descriptor: ()Ljava/util/stream/BaseStream;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
iconst_0
putfield java.util.stream.AbstractPipeline.parallel:Z
1: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
Signature: ()TS;
public final S parallel();
descriptor: ()Ljava/util/stream/BaseStream;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
iconst_1
putfield java.util.stream.AbstractPipeline.parallel:Z
1: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
Signature: ()TS;
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
iconst_1
putfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
1: aload 0
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
2: aload 0
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
3: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceCloseAction:Ljava/lang/Runnable;
ifnull 7
4: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceCloseAction:Ljava/lang/Runnable;
astore 1
start local 1 5: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
aconst_null
putfield java.util.stream.AbstractPipeline.sourceCloseAction:Ljava/lang/Runnable;
6: aload 1
invokeinterface java.lang.Runnable.run:()V
end local 1 7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
5 7 1 closeAction Ljava/lang/Runnable;
public S onClose(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Ljava/util/stream/BaseStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "stream has already been operated upon or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceCloseAction:Ljava/lang/Runnable;
astore 2
start local 2 4: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
5: aload 2
ifnonnull 7
6: aload 1
goto 8
7: StackMap locals: java.util.stream.AbstractPipeline java.lang.Runnable java.lang.Runnable
StackMap stack: java.util.stream.AbstractPipeline
aload 2
aload 1
invokestatic java.util.stream.Streams.composeWithExceptions:(Ljava/lang/Runnable;Ljava/lang/Runnable;)Ljava/lang/Runnable;
8: StackMap locals: java.util.stream.AbstractPipeline java.lang.Runnable java.lang.Runnable
StackMap stack: java.util.stream.AbstractPipeline java.lang.Runnable
putfield java.util.stream.AbstractPipeline.sourceCloseAction:Ljava/lang/Runnable;
9: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 10 1 closeHandler Ljava/lang/Runnable;
4 10 2 existingHandler Ljava/lang/Runnable;
Signature: (Ljava/lang/Runnable;)TS;
MethodParameters:
Name Flags
closeHandler
public java.util.Spliterator<E_OUT> spliterator();
descriptor: ()Ljava/util/Spliterator;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "stream has already been operated upon or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield java.util.stream.AbstractPipeline.linkedOrConsumed:Z
3: aload 0
aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
if_acmpne 13
4: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
ifnull 8
5: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
astore 1
start local 1 6: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
7: aload 1
areturn
end local 1 8: StackMap locals:
StackMap stack:
aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
ifnull 12
9: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
astore 1
start local 1 10: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
11: aload 0
aload 1
invokevirtual java.util.stream.AbstractPipeline.lazySpliterator:(Ljava/util/function/Supplier;)Ljava/util/Spliterator;
areturn
end local 1 12: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "source already consumed or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
13: StackMap locals:
StackMap stack:
aload 0
aload 0
aload 0
invokedynamic get(Ljava/util/stream/AbstractPipeline;)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;
java/util/stream/AbstractPipeline.lambda$0()Ljava/util/Spliterator; (7)
()Ljava/util/Spliterator;
aload 0
invokevirtual java.util.stream.AbstractPipeline.isParallel:()Z
invokevirtual java.util.stream.AbstractPipeline.wrap:(Ljava/util/stream/PipelineHelper;Ljava/util/function/Supplier;Z)Ljava/util/Spliterator;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
6 8 1 s Ljava/util/Spliterator<TE_OUT;>;
10 12 1 s Ljava/util/function/Supplier<Ljava/util/Spliterator<TE_OUT;>;>;
Signature: ()Ljava/util/Spliterator<TE_OUT;>;
public final boolean isParallel();
descriptor: ()Z
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.parallel:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
final int getStreamFlags();
descriptor: ()I
flags: (0x0010) ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield java.util.stream.AbstractPipeline.combinedFlags:I
invokestatic java.util.stream.StreamOpFlag.toStreamFlags:(I)I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
private java.util.Spliterator<?> sourceSpliterator(int);
descriptor: (I)Ljava/util/Spliterator;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=8, args_size=2
start local 0 start local 1 0: aconst_null
astore 2
start local 2 1: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
ifnull 5
2: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
astore 2
3: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSpliterator:Ljava/util/Spliterator;
4: goto 10
5: StackMap locals: java.util.Spliterator
StackMap stack:
aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
ifnull 9
6: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.Spliterator
astore 2
7: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
aconst_null
putfield java.util.stream.AbstractPipeline.sourceSupplier:Ljava/util/function/Supplier;
8: goto 10
9: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "source already consumed or closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
10: StackMap locals:
StackMap stack:
aload 0
invokevirtual java.util.stream.AbstractPipeline.isParallel:()Z
ifeq 30
aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.sourceAnyStateful:Z
ifeq 30
11: iconst_1
istore 3
start local 3 12: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
astore 4
start local 4 13: aload 0
getfield java.util.stream.AbstractPipeline.sourceStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.nextStage:Ljava/util/stream/AbstractPipeline;
astore 5
start local 5 14: aload 0
astore 6
start local 6 15: goto 29
16: StackMap locals: java.util.stream.AbstractPipeline int java.util.Spliterator int java.util.stream.AbstractPipeline java.util.stream.AbstractPipeline java.util.stream.AbstractPipeline
StackMap stack:
aload 5
getfield java.util.stream.AbstractPipeline.sourceOrOpFlags:I
istore 7
start local 7 17: aload 5
invokevirtual java.util.stream.AbstractPipeline.opIsStateful:()Z
ifeq 26
18: iconst_0
istore 3
19: getstatic java.util.stream.StreamOpFlag.SHORT_CIRCUIT:Ljava/util/stream/StreamOpFlag;
iload 7
invokevirtual java.util.stream.StreamOpFlag.isKnown:(I)Z
ifeq 21
20: iload 7
getstatic java.util.stream.StreamOpFlag.IS_SHORT_CIRCUIT:I
iconst_m1
ixor
iand
istore 7
21: StackMap locals: int
StackMap stack:
aload 5
aload 4
aload 2
invokevirtual java.util.stream.AbstractPipeline.opEvaluateParallelLazy:(Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;)Ljava/util/Spliterator;
astore 2
22: aload 2
bipush 64
invokeinterface java.util.Spliterator.hasCharacteristics:(I)Z
ifeq 24
23: iload 7
getstatic java.util.stream.StreamOpFlag.NOT_SIZED:I
iconst_m1
ixor
iand
getstatic java.util.stream.StreamOpFlag.IS_SIZED:I
ior
goto 25
24: StackMap locals:
StackMap stack:
iload 7
getstatic java.util.stream.StreamOpFlag.IS_SIZED:I
iconst_m1
ixor
iand
getstatic java.util.stream.StreamOpFlag.NOT_SIZED:I
ior
25: StackMap locals:
StackMap stack: int
istore 7
26: StackMap locals:
StackMap stack:
aload 5
iload 3
iinc 3 1
putfield java.util.stream.AbstractPipeline.depth:I
27: aload 5
iload 7
aload 4
getfield java.util.stream.AbstractPipeline.combinedFlags:I
invokestatic java.util.stream.StreamOpFlag.combineOpFlags:(II)I
putfield java.util.stream.AbstractPipeline.combinedFlags:I
end local 7 28: aload 5
astore 4
aload 5
getfield java.util.stream.AbstractPipeline.nextStage:Ljava/util/stream/AbstractPipeline;
astore 5
29: StackMap locals:
StackMap stack:
aload 4
aload 6
if_acmpne 16
end local 6 end local 5 end local 4 end local 3 30: StackMap locals: java.util.stream.AbstractPipeline int java.util.Spliterator
StackMap stack:
iload 1
ifeq 32
31: aload 0
iload 1
aload 0
getfield java.util.stream.AbstractPipeline.combinedFlags:I
invokestatic java.util.stream.StreamOpFlag.combineOpFlags:(II)I
putfield java.util.stream.AbstractPipeline.combinedFlags:I
32: StackMap locals:
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 33 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 33 1 terminalFlags I
1 33 2 spliterator Ljava/util/Spliterator<*>;
12 30 3 depth I
13 30 4 u Ljava/util/stream/AbstractPipeline;
14 30 5 p Ljava/util/stream/AbstractPipeline;
15 30 6 e Ljava/util/stream/AbstractPipeline;
17 28 7 thisOpFlags I
Signature: (I)Ljava/util/Spliterator<*>;
MethodParameters:
Name Flags
terminalFlags
final java.util.stream.StreamShape getSourceShape();
descriptor: ()Ljava/util/stream/StreamShape;
flags: (0x0010) ACC_FINAL
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
astore 1
start local 1 1: goto 3
2: StackMap locals: java.util.stream.AbstractPipeline
StackMap stack:
aload 1
getfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
astore 1
3: StackMap locals:
StackMap stack:
aload 1
getfield java.util.stream.AbstractPipeline.depth:I
ifgt 2
4: aload 1
invokevirtual java.util.stream.AbstractPipeline.getOutputShape:()Ljava/util/stream/StreamShape;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
1 5 1 p Ljava/util/stream/AbstractPipeline;
final <P_IN> long exactOutputSizeIfKnown(java.util.Spliterator<P_IN>);
descriptor: (Ljava/util/Spliterator;)J
flags: (0x0010) ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic java.util.stream.StreamOpFlag.SIZED:Ljava/util/stream/StreamOpFlag;
aload 0
invokevirtual java.util.stream.AbstractPipeline.getStreamAndOpFlags:()I
invokevirtual java.util.stream.StreamOpFlag.isKnown:(I)Z
ifeq 1
aload 1
invokeinterface java.util.Spliterator.getExactSizeIfKnown:()J
goto 2
StackMap locals:
StackMap stack:
1: ldc -1
StackMap locals:
StackMap stack: long
2: lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 3 1 spliterator Ljava/util/Spliterator<TP_IN;>;
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/Spliterator<TP_IN;>;)J
MethodParameters:
Name Flags
spliterator
final <P_IN, S extends java.util.stream.Sink<E_OUT>> S wrapAndCopyInto(S, java.util.Spliterator<P_IN>);
descriptor: (Ljava/util/stream/Sink;Ljava/util/Spliterator;)Ljava/util/stream/Sink;
flags: (0x0010) ACC_FINAL
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 0
aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.stream.Sink
invokevirtual java.util.stream.AbstractPipeline.wrapSink:(Ljava/util/stream/Sink;)Ljava/util/stream/Sink;
aload 2
invokevirtual java.util.stream.AbstractPipeline.copyInto:(Ljava/util/stream/Sink;Ljava/util/Spliterator;)V
1: aload 1
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 2 1 sink TS;
0 2 2 spliterator Ljava/util/Spliterator<TP_IN;>;
Signature: <P_IN:Ljava/lang/Object;S::Ljava/util/stream/Sink<TE_OUT;>;>(TS;Ljava/util/Spliterator<TP_IN;>;)TS;
MethodParameters:
Name Flags
sink
spliterator
final <P_IN> void copyInto(java.util.stream.Sink<P_IN>, java.util.Spliterator<P_IN>);
descriptor: (Ljava/util/stream/Sink;Ljava/util/Spliterator;)V
flags: (0x0010) ACC_FINAL
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: getstatic java.util.stream.StreamOpFlag.SHORT_CIRCUIT:Ljava/util/stream/StreamOpFlag;
aload 0
invokevirtual java.util.stream.AbstractPipeline.getStreamAndOpFlags:()I
invokevirtual java.util.stream.StreamOpFlag.isKnown:(I)Z
ifne 6
2: aload 1
aload 2
invokeinterface java.util.Spliterator.getExactSizeIfKnown:()J
invokeinterface java.util.stream.Sink.begin:(J)V
3: aload 2
aload 1
invokeinterface java.util.Spliterator.forEachRemaining:(Ljava/util/function/Consumer;)V
4: aload 1
invokeinterface java.util.stream.Sink.end:()V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
invokevirtual java.util.stream.AbstractPipeline.copyIntoWithCancel:(Ljava/util/stream/Sink;Ljava/util/Spliterator;)Z
pop
7: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 8 1 wrappedSink Ljava/util/stream/Sink<TP_IN;>;
0 8 2 spliterator Ljava/util/Spliterator<TP_IN;>;
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/stream/Sink<TP_IN;>;Ljava/util/Spliterator<TP_IN;>;)V
MethodParameters:
Name Flags
wrappedSink
spliterator
final <P_IN> boolean copyIntoWithCancel(java.util.stream.Sink<P_IN>, java.util.Spliterator<P_IN>);
descriptor: (Ljava/util/stream/Sink;Ljava/util/Spliterator;)Z
flags: (0x0010) ACC_FINAL
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
astore 3
start local 3 1: goto 3
2: StackMap locals: java.util.stream.AbstractPipeline
StackMap stack:
aload 3
getfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
astore 3
3: StackMap locals:
StackMap stack:
aload 3
getfield java.util.stream.AbstractPipeline.depth:I
ifgt 2
4: aload 1
aload 2
invokeinterface java.util.Spliterator.getExactSizeIfKnown:()J
invokeinterface java.util.stream.Sink.begin:(J)V
5: aload 3
aload 2
aload 1
invokevirtual java.util.stream.AbstractPipeline.forEachWithCancel:(Ljava/util/Spliterator;Ljava/util/stream/Sink;)Z
istore 4
start local 4 6: aload 1
invokeinterface java.util.stream.Sink.end:()V
7: iload 4
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 8 1 wrappedSink Ljava/util/stream/Sink<TP_IN;>;
0 8 2 spliterator Ljava/util/Spliterator<TP_IN;>;
1 8 3 p Ljava/util/stream/AbstractPipeline;
6 8 4 cancelled Z
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/stream/Sink<TP_IN;>;Ljava/util/Spliterator<TP_IN;>;)Z
MethodParameters:
Name Flags
wrappedSink
spliterator
final int getStreamAndOpFlags();
descriptor: ()I
flags: (0x0010) ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield java.util.stream.AbstractPipeline.combinedFlags:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
final boolean isOrdered();
descriptor: ()Z
flags: (0x0010) ACC_FINAL
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.util.stream.StreamOpFlag.ORDERED:Ljava/util/stream/StreamOpFlag;
aload 0
getfield java.util.stream.AbstractPipeline.combinedFlags:I
invokevirtual java.util.stream.StreamOpFlag.isKnown:(I)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
final <P_IN> java.util.stream.Sink<P_IN> wrapSink(java.util.stream.Sink<E_OUT>);
descriptor: (Ljava/util/stream/Sink;)Ljava/util/stream/Sink;
flags: (0x0010) ACC_FINAL
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
astore 2
start local 2 2: goto 5
3: StackMap locals: java.util.stream.AbstractPipeline
StackMap stack:
aload 2
aload 2
getfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
getfield java.util.stream.AbstractPipeline.combinedFlags:I
aload 1
invokevirtual java.util.stream.AbstractPipeline.opWrapSink:(ILjava/util/stream/Sink;)Ljava/util/stream/Sink;
astore 1
4: aload 2
getfield java.util.stream.AbstractPipeline.previousStage:Ljava/util/stream/AbstractPipeline;
astore 2
StackMap locals:
StackMap stack:
5: aload 2
getfield java.util.stream.AbstractPipeline.depth:I
ifgt 3
end local 2 6: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 7 1 sink Ljava/util/stream/Sink<TE_OUT;>;
2 6 2 p Ljava/util/stream/AbstractPipeline;
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/stream/Sink<TE_OUT;>;)Ljava/util/stream/Sink<TP_IN;>;
MethodParameters:
Name Flags
sink
final <P_IN> java.util.Spliterator<E_OUT> wrapSpliterator(java.util.Spliterator<P_IN>);
descriptor: (Ljava/util/Spliterator;)Ljava/util/Spliterator;
flags: (0x0010) ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield java.util.stream.AbstractPipeline.depth:I
ifne 2
1: aload 1
areturn
2: StackMap locals:
StackMap stack:
aload 0
aload 0
aload 1
invokedynamic get(Ljava/util/Spliterator;)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;
java/util/stream/AbstractPipeline.lambda$1(Ljava/util/Spliterator;)Ljava/util/Spliterator; (6)
()Ljava/util/Spliterator;
aload 0
invokevirtual java.util.stream.AbstractPipeline.isParallel:()Z
invokevirtual java.util.stream.AbstractPipeline.wrap:(Ljava/util/stream/PipelineHelper;Ljava/util/function/Supplier;Z)Ljava/util/Spliterator;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 3 1 sourceSpliterator Ljava/util/Spliterator<TP_IN;>;
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/Spliterator<TP_IN;>;)Ljava/util/Spliterator<TE_OUT;>;
MethodParameters:
Name Flags
sourceSpliterator
final <P_IN> java.util.stream.Node<E_OUT> evaluate(java.util.Spliterator<P_IN>, boolean, java.util.function.IntFunction<E_OUT[]>);
descriptor: (Ljava/util/Spliterator;ZLjava/util/function/IntFunction;)Ljava/util/stream/Node;
flags: (0x0010) ACC_FINAL
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual java.util.stream.AbstractPipeline.isParallel:()Z
ifeq 2
1: aload 0
aload 0
aload 1
iload 2
aload 3
invokevirtual java.util.stream.AbstractPipeline.evaluateToNode:(Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;ZLjava/util/function/IntFunction;)Ljava/util/stream/Node;
areturn
2: StackMap locals:
StackMap stack:
aload 0
3: aload 0
aload 1
invokevirtual java.util.stream.AbstractPipeline.exactOutputSizeIfKnown:(Ljava/util/Spliterator;)J
aload 3
4: invokevirtual java.util.stream.AbstractPipeline.makeNodeBuilder:(JLjava/util/function/IntFunction;)Ljava/util/stream/Node$Builder;
astore 4
start local 4 5: aload 0
aload 4
aload 1
invokevirtual java.util.stream.AbstractPipeline.wrapAndCopyInto:(Ljava/util/stream/Sink;Ljava/util/Spliterator;)Ljava/util/stream/Sink;
checkcast java.util.stream.Node$Builder
invokeinterface java.util.stream.Node$Builder.build:()Ljava/util/stream/Node;
areturn
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 Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 6 1 spliterator Ljava/util/Spliterator<TP_IN;>;
0 6 2 flatten Z
0 6 3 generator Ljava/util/function/IntFunction<[TE_OUT;>;
5 6 4 nb Ljava/util/stream/Node$Builder<TE_OUT;>;
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/Spliterator<TP_IN;>;ZLjava/util/function/IntFunction<[TE_OUT;>;)Ljava/util/stream/Node<TE_OUT;>;
MethodParameters:
Name Flags
spliterator
flatten
generator
abstract java.util.stream.StreamShape getOutputShape();
descriptor: ()Ljava/util/stream/StreamShape;
flags: (0x0400) ACC_ABSTRACT
abstract <P_IN> java.util.stream.Node<E_OUT> evaluateToNode(java.util.stream.PipelineHelper<E_OUT>, java.util.Spliterator<P_IN>, boolean, java.util.function.IntFunction<E_OUT[]>);
descriptor: (Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;ZLjava/util/function/IntFunction;)Ljava/util/stream/Node;
flags: (0x0400) ACC_ABSTRACT
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/stream/PipelineHelper<TE_OUT;>;Ljava/util/Spliterator<TP_IN;>;ZLjava/util/function/IntFunction<[TE_OUT;>;)Ljava/util/stream/Node<TE_OUT;>;
MethodParameters:
Name Flags
helper
spliterator
flattenTree
generator
abstract <P_IN> java.util.Spliterator<E_OUT> wrap(java.util.stream.PipelineHelper<E_OUT>, java.util.function.Supplier<java.util.Spliterator<P_IN>>, boolean);
descriptor: (Ljava/util/stream/PipelineHelper;Ljava/util/function/Supplier;Z)Ljava/util/Spliterator;
flags: (0x0400) ACC_ABSTRACT
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/stream/PipelineHelper<TE_OUT;>;Ljava/util/function/Supplier<Ljava/util/Spliterator<TP_IN;>;>;Z)Ljava/util/Spliterator<TE_OUT;>;
MethodParameters:
Name Flags
ph
supplier
isParallel
abstract java.util.Spliterator<E_OUT> lazySpliterator(java.util.function.Supplier<? extends java.util.Spliterator<E_OUT>>);
descriptor: (Ljava/util/function/Supplier;)Ljava/util/Spliterator;
flags: (0x0400) ACC_ABSTRACT
Signature: (Ljava/util/function/Supplier<+Ljava/util/Spliterator<TE_OUT;>;>;)Ljava/util/Spliterator<TE_OUT;>;
MethodParameters:
Name Flags
supplier
abstract boolean forEachWithCancel(java.util.Spliterator<E_OUT>, java.util.stream.Sink<E_OUT>);
descriptor: (Ljava/util/Spliterator;Ljava/util/stream/Sink;)Z
flags: (0x0400) ACC_ABSTRACT
Signature: (Ljava/util/Spliterator<TE_OUT;>;Ljava/util/stream/Sink<TE_OUT;>;)Z
MethodParameters:
Name Flags
spliterator
sink
abstract java.util.stream.Node$Builder<E_OUT> makeNodeBuilder(long, java.util.function.IntFunction<E_OUT[]>);
descriptor: (JLjava/util/function/IntFunction;)Ljava/util/stream/Node$Builder;
flags: (0x0400) ACC_ABSTRACT
Signature: (JLjava/util/function/IntFunction<[TE_OUT;>;)Ljava/util/stream/Node$Builder<TE_OUT;>;
MethodParameters:
Name Flags
exactSizeIfKnown
generator
abstract boolean opIsStateful();
descriptor: ()Z
flags: (0x0400) ACC_ABSTRACT
abstract java.util.stream.Sink<E_IN> opWrapSink(int, java.util.stream.Sink<E_OUT>);
descriptor: (ILjava/util/stream/Sink;)Ljava/util/stream/Sink;
flags: (0x0400) ACC_ABSTRACT
Signature: (ILjava/util/stream/Sink<TE_OUT;>;)Ljava/util/stream/Sink<TE_IN;>;
MethodParameters:
Name Flags
flags
sink
<P_IN> java.util.stream.Node<E_OUT> opEvaluateParallel(java.util.stream.PipelineHelper<E_OUT>, java.util.Spliterator<P_IN>, java.util.function.IntFunction<E_OUT[]>);
descriptor: (Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;Ljava/util/function/IntFunction;)Ljava/util/stream/Node;
flags: (0x0000)
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.lang.UnsupportedOperationException
dup
ldc "Parallel evaluation is not supported"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 1 1 helper Ljava/util/stream/PipelineHelper<TE_OUT;>;
0 1 2 spliterator Ljava/util/Spliterator<TP_IN;>;
0 1 3 generator Ljava/util/function/IntFunction<[TE_OUT;>;
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/stream/PipelineHelper<TE_OUT;>;Ljava/util/Spliterator<TP_IN;>;Ljava/util/function/IntFunction<[TE_OUT;>;)Ljava/util/stream/Node<TE_OUT;>;
MethodParameters:
Name Flags
helper
spliterator
generator
<P_IN> java.util.Spliterator<E_OUT> opEvaluateParallelLazy(java.util.stream.PipelineHelper<E_OUT>, java.util.Spliterator<P_IN>);
descriptor: (Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;)Ljava/util/Spliterator;
flags: (0x0000)
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokedynamic apply()Ljava/util/function/IntFunction;
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:
(I)Ljava/lang/Object;
java/util/stream/AbstractPipeline.lambda$2(I)[Ljava/lang/Object; (6)
(I)[Ljava/lang/Object;
invokevirtual java.util.stream.AbstractPipeline.opEvaluateParallel:(Ljava/util/stream/PipelineHelper;Ljava/util/Spliterator;Ljava/util/function/IntFunction;)Ljava/util/stream/Node;
invokeinterface java.util.stream.Node.spliterator:()Ljava/util/Spliterator;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
0 1 1 helper Ljava/util/stream/PipelineHelper<TE_OUT;>;
0 1 2 spliterator Ljava/util/Spliterator<TP_IN;>;
Signature: <P_IN:Ljava/lang/Object;>(Ljava/util/stream/PipelineHelper<TE_OUT;>;Ljava/util/Spliterator<TP_IN;>;)Ljava/util/Spliterator<TE_OUT;>;
MethodParameters:
Name Flags
helper
spliterator
private java.util.Spliterator lambda$0();
descriptor: ()Ljava/util/Spliterator;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
invokevirtual java.util.stream.AbstractPipeline.sourceSpliterator:(I)Ljava/util/Spliterator;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljava/util/stream/AbstractPipeline<TE_IN;TE_OUT;TS;>;
private static java.util.Spliterator lambda$1(java.util.Spliterator);
descriptor: (Ljava/util/Spliterator;)Ljava/util/Spliterator;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.Object[] lambda$2(int);
descriptor: (I)[Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: iload 0
anewarray java.lang.Object
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 i I
}
Signature: <E_IN:Ljava/lang/Object;E_OUT:Ljava/lang/Object;S::Ljava/util/stream/BaseStream<TE_OUT;TS;>;>Ljava/util/stream/PipelineHelper<TE_OUT;>;Ljava/util/stream/BaseStream<TE_OUT;TS;>;
SourceFile: "AbstractPipeline.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Builder = java.util.stream.Node$Builder of java.util.stream.Node