Uses of Class
org.ek9lang.antlr.EK9Parser.StreamPartContext

Packages that use EK9Parser.StreamPartContext

Package	Description
org.ek9lang.antlr
org.ek9lang.compiler.phase1	E - Initial Symbol definition by traversing the 'ANTLR' - 'AST'.
org.ek9lang.compiler.phase3	G - Full Symbol Resolution can now take place.
org.ek9lang.compiler.phase5	I - PRE Intermediate Representation generation checks.
org.ek9lang.compiler.phase7.generator
org.ek9lang.compiler.support	Contains critical general components used in the Ek9Compiler listeners.

Uses of EK9Parser.StreamPartContext in org.ek9lang.antlr

Methods in org.ek9lang.antlr that return EK9Parser.StreamPartContext

Modifier and Type	Method	Description
EK9Parser.StreamPartContext	EK9Parser.StreamExpressionContext.streamPart(int i)
final EK9Parser.StreamPartContext	EK9Parser.streamPart()
EK9Parser.StreamPartContext	EK9Parser.StreamStatementContext.streamPart(int i)

Methods in org.ek9lang.antlr that return types with arguments of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
List<EK9Parser.StreamPartContext>	EK9Parser.StreamExpressionContext.streamPart()
List<EK9Parser.StreamPartContext>	EK9Parser.StreamStatementContext.streamPart()

Methods in org.ek9lang.antlr with parameters of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
void	EK9BaseListener.enterStreamPart(EK9Parser.StreamPartContext ctx)	Enter a parse tree produced by EK9Parser.streamPart().
void	EK9Listener.enterStreamPart(EK9Parser.StreamPartContext ctx)	Enter a parse tree produced by EK9Parser.streamPart().
void	EK9BaseListener.exitStreamPart(EK9Parser.StreamPartContext ctx)	Exit a parse tree produced by EK9Parser.streamPart().
void	EK9Listener.exitStreamPart(EK9Parser.StreamPartContext ctx)	Exit a parse tree produced by EK9Parser.streamPart().
T	EK9BaseVisitor.visitStreamPart(EK9Parser.StreamPartContext ctx)	Visit a parse tree produced by EK9Parser.streamPart().
T	EK9Visitor.visitStreamPart(EK9Parser.StreamPartContext ctx)	Visit a parse tree produced by EK9Parser.streamPart().

Uses of EK9Parser.StreamPartContext in org.ek9lang.compiler.phase1

Methods in org.ek9lang.compiler.phase1 with parameters of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
void	DefinitionListener.enterStreamPart(EK9Parser.StreamPartContext ctx)

Uses of EK9Parser.StreamPartContext in org.ek9lang.compiler.phase3

Classes in org.ek9lang.compiler.phase3 that implement interfaces with type arguments of type EK9Parser.StreamPartContext

Modifier and Type	Class	Description
(package private) final class	HeadTailSkipOrError	Checks the possible operation variable, literal or function for suitability for use with 'head', 'tail' and 'skip'.

Methods in org.ek9lang.compiler.phase3 that return types with arguments of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
List<EK9Parser.StreamPartContext>	StreamAssemblyData.streamParts()	Returns the value of the streamParts record component.

Methods in org.ek9lang.compiler.phase3 with parameters of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
void	HeadTailSkipOrError.accept(EK9Parser.StreamPartContext ctx)

Constructor parameters in org.ek9lang.compiler.phase3 with type arguments of type EK9Parser.StreamPartContext

Modifier	Constructor	Description
	StreamAssemblyData(StreamCallSymbol source, List<EK9Parser.StreamPartContext> streamParts, StreamCallSymbol termination)	Creates an instance of a StreamAssemblyData record class.

Uses of EK9Parser.StreamPartContext in org.ek9lang.compiler.phase5

Methods in org.ek9lang.compiler.phase5 with parameters of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
void	LockAnalysisListener.enterStreamPart(EK9Parser.StreamPartContext ctx)
void	PreIRListener.enterStreamPart(EK9Parser.StreamPartContext ctx)

Uses of EK9Parser.StreamPartContext in org.ek9lang.compiler.phase7.generator

Methods in org.ek9lang.compiler.phase7.generator that return EK9Parser.StreamPartContext

Modifier and Type	Method	Description
EK9Parser.StreamPartContext	StageWrapParams.stageCtx()	Returns the value of the stageCtx record component.

Methods in org.ek9lang.compiler.phase7.generator that return types with arguments of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
List<EK9Parser.StreamPartContext>	StageGroup.stages()	Returns the value of the stages record component.

Methods in org.ek9lang.compiler.phase7.generator with parameters of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
(package private) void	StreamEmissionEngine.applyAsyncBufferSortEmit(String asyncExecutorVar, ISymbol asyncProducesType, List<EK9Parser.StreamPartContext> preSortStages, EK9Parser.StreamPartContext sortStage, List<EK9Parser.StreamPartContext> postSortStages, TerminalSetup terminalSetup, DebugInfo debugInfo, List<IRInstr> instructions)	Async-specific entry to StreamEmissionEngine.bufferSortEmit(String, String, String, String, CallDetails, ISymbol, List, EK9Parser.StreamPartContext, List, TerminalSetup, DebugInfo, List): drains the async executor (hasNext/next) and closes it after emission.
(package private) void	StreamEmissionEngine.bufferSortEmit(String sourceVar, String sourceTypeName, String hasNextMethod, String nextMethod, CallDetails closeCall, ISymbol bucketType, List<EK9Parser.StreamPartContext> preSortStages, EK9Parser.StreamPartContext sortStage, List<EK9Parser.StreamPartContext> postSortStages, TerminalSetup terminalSetup, DebugInfo debugInfo, List<IRInstr> instructions)
(package private) ISymbol	StreamPipelineMachinery.edgeConsumes(EK9Parser.StreamPartContext stage)	The phase-3-resolved IN-edge (consumes) type of a stream stage, or null if unresolved.
(package private) ISymbol	StreamPipelineMachinery.edgeProduces(EK9Parser.StreamPartContext stage)	The phase-3-resolved OUT-edge (produces) type of a stream stage, or null if the stage has no recorded StreamCallSymbol or no produced type set.
(package private) List<IRInstr>	StreamPipelineMachinery.generateDynamicStageLimit(EK9Parser.StreamPartContext stageCtx, String limitVar, ISymbol integerType, String scopeId, DebugInfo debugInfo)	Generate IR to evaluate a dynamic stage operand (function reference or call) and store the Integer result in the given limit variable.
(package private) SortAndIteratorResult	StreamPipelineMachinery.sortBufferAndGetIterator(EK9Parser.StreamPartContext sortStage, String bufferVar, DebugInfo debugInfo)	Sort a raw org.ek9.lang::List buffer in place and return an iterator over the sorted result.

Method parameters in org.ek9lang.compiler.phase7.generator with type arguments of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
(package private) void	StreamEmissionEngine.applyAsyncBufferSortEmit(String asyncExecutorVar, ISymbol asyncProducesType, List<EK9Parser.StreamPartContext> preSortStages, EK9Parser.StreamPartContext sortStage, List<EK9Parser.StreamPartContext> postSortStages, TerminalSetup terminalSetup, DebugInfo debugInfo, List<IRInstr> instructions)	Async-specific entry to StreamEmissionEngine.bufferSortEmit(String, String, String, String, CallDetails, ISymbol, List, EK9Parser.StreamPartContext, List, TerminalSetup, DebugInfo, List): drains the async executor (hasNext/next) and closes it after emission.
(package private) SortSetup	StreamEmissionEngine.applySortToCollection(List<EK9Parser.StreamPartContext> stages, IteratorSetup iteratorSetup, ISymbol elementType, IAggregateSymbol collectionType, DebugInfo debugInfo, List<IRInstr> instructions, boolean sourceUnbounded)
(package private) void	StreamEmissionEngine.applyWindowedAsyncToCollection(List<EK9Parser.StreamPartContext> stages, int asyncIndex, List<EK9Parser.StreamPartContext> preAsyncStages, List<StageState> preAsyncStageStates, IteratorSetup iteratorSetup, ISymbol elementType, ISymbol asyncProducesType, String asyncExecutorVar, TerminalSetup terminalSetup, DebugInfo debugInfo, List<IRInstr> instructions)	Step C — the interleaved WINDOWED async driver for an unbounded source (the telemetry case cat udp | async | filter | head N | collect).
(package private) void	StreamEmissionEngine.bufferSortEmit(String sourceVar, String sourceTypeName, String hasNextMethod, String nextMethod, CallDetails closeCall, ISymbol bucketType, List<EK9Parser.StreamPartContext> preSortStages, EK9Parser.StreamPartContext sortStage, List<EK9Parser.StreamPartContext> postSortStages, TerminalSetup terminalSetup, DebugInfo debugInfo, List<IRInstr> instructions)
(package private) StageWrapResult	StreamEmissionEngine.buildAsyncSubmitAction(String submitItemVar, ISymbol elementType, String asyncExecutorVar, String inFlightVar, String oneVar, ISymbol integerType, List<EK9Parser.StreamPartContext> preAsyncStages, List<StageState> preAsyncStageStates, DebugInfo debugInfo)	The per-item SUBMIT action shared by the windowed prime loop and the drain refill: executor.submit(item); inFlight++, wrapped in the pre-ASYNC stages (filter/map/etc.).
(package private) List<IRInstr>	StreamEmissionEngine.buildWindowRefill(IteratorSetup iteratorSetup, boolean isRawIterator, String submitItemVar, ISymbol elementType, String asyncExecutorVar, String inFlightVar, String oneVar, ISymbol integerType, List<EK9Parser.StreamPartContext> preAsyncStages, List<StageState> preAsyncStageStates, String moreVar, DebugInfo debugInfo)	The windowed drain's REFILL step: if (more AND source.hasNext()) { bind submitItem = next(); [pre-async stages]; submit(submitItem); inFlight++ }.
(package private) boolean	StreamPipelineMachinery.containsBufferBarrier(List<EK9Parser.StreamPartContext> stages)	True if any stage is a pre-loop buffer-barrier (sort/group/split/tail) — these cannot be composed by the windowed async driver and (on an unbounded async) are rejected at phase 3.
(package private) boolean	StreamPipelineMachinery.containsBufferingCollection(List<EK9Parser.StreamPartContext> stages)	True iff stages contains a GROUP/SPLIT/ASYNC collection-buffer stage.
(package private) void	StreamEmissionEngine.continueOverIterator(List<EK9Parser.StreamPartContext> stages, IteratorSetup sourceIter, ISymbol sourceElementType, TerminalSetup terminalSetup, DebugInfo debugInfo, List<IRInstr> instructions, boolean sourceUnbounded)	Recursive pipeline TAIL driver: emit a stream given as sourceIter through stages to the terminal, with NO composition limit.
(package private) ISymbol	StreamPipelineMachinery.effectivePostSortElementType(SortSetup sortSetup, List<EK9Parser.StreamPartContext> allStages, ISymbol sourceType)	The element type the POST-sort pipeline (and terminal) observe.
(package private) StageState	StreamPipelineMachinery.findHeadStageState(List<EK9Parser.StreamPartContext> stages, List<StageState> stageStates)	Locate the StageState of the first HEAD stage (carries counter/limit), or null if no HEAD present.
(package private) ConditionAndPostLoop	StreamEmissionEngine.generateConditionAndBody(EK9Parser.StreamStatementContext ctx, EK9Parser.StreamCatContext catCtx, List<EK9Parser.StreamPartContext> stages, IteratorSetup iteratorSetup, String pipelineItemVar, ISymbol elementType, TerminalSetup terminalSetup, DebugInfo debugInfo, List<StageState> stageStates, boolean rawIterator, String pipelineScopeId, List<IRInstr> preLoopInstructions, boolean sourceUnbounded)	Generate condition (hasNext) and body (next + stages + terminal pipe).
(package private) StageSetupResult	StreamPipelineMachinery.generateStageSetup(List<EK9Parser.StreamPartContext> stages, String scopeId, DebugInfo debugInfo)	Generate pre-loop state initialization for stateful pipeline stages (HEAD, SKIPPING, TAIL).
(package private) int	StreamPipelineMachinery.indexOfFirstCollectionBuffer(List<EK9Parser.StreamPartContext> stages)	Index of the first GROUP/SPLIT/ASYNC collection-buffer stage in stages, or -1.
(package private) int	StreamPipelineMachinery.indexOfFirstSort(List<EK9Parser.StreamPartContext> stages)	Index of the first SORT stage in stages, or -1.
(package private) PipelineVarPlan	StreamPipelineMachinery.planPipelineVars(List<EK9Parser.StreamPartContext> stages, String sourceVar, ISymbol sourceType, String scopeId, DebugInfo debugInfo, List<IRInstr> declarationsOut)	Compute the per-boundary item-variable plan for an in-loop stage list, allocating a fresh variable (declared at the produced type) only where a stage changes the element type.
(package private) boolean	StreamPipelineMachinery.sortReachableBeforeBuffer(List<EK9Parser.StreamPartContext> stages)	True iff the NEXT buffering SORT in stages is reachable with no intervening collection-buffer (GROUP/SPLIT/ASYNC).
(package private) StageWrapResult	StreamEmissionEngine.terminalBodyTail(List<EK9Parser.StreamPartContext> stages, String itemVar, ISymbol itemType, TerminalSetup terminalSetup, String scopeId, List<IRInstr> preLoopInstructions, List<StageState> stageStates, DebugInfo debugInfo)	The shared stream body-tail, used identically by the cat path (the StreamPipelineMachinery.buildStreamLoop(IteratorSetup, StageState, String, ISymbol, boolean, EK9Parser.StreamCatContext, StreamLoopSink, DebugInfo) sink) and the for-range streaming body: plan the per-boundary item vars (declared pre-loop in preLoopInstructions so a post-loop consumer like JOIN's emit references a dominating var), pipe the final-typed item to the terminal, and wrap the result in the intermediate stages.
(package private) StageWrapResult	StreamStageDispatcher.wrapWithStages(List<EK9Parser.StreamPartContext> stages, List<IRInstr> innerBody, String pipelineItemVar, ISymbol elementType, DebugInfo debugInfo, List<StageState> stageStates)	Wrap inner body instructions with intermediate pipeline stages in reverse order.
(package private) StageWrapResult	StreamStageDispatcher.wrapWithStages(List<EK9Parser.StreamPartContext> stages, List<IRInstr> innerBody, String pipelineItemVar, ISymbol elementType, DebugInfo debugInfo, List<StageState> stageStates, String asyncExecutorVar)	Wrap inner body instructions with intermediate pipeline stages in reverse order.
(package private) StageWrapResult	StreamStageDispatcher.wrapWithStages(List<EK9Parser.StreamPartContext> stages, List<IRInstr> innerBody, String pipelineItemVar, ISymbol elementType, DebugInfo debugInfo, List<StageState> stageStates, String asyncExecutorVar, PipelineVarPlan plan)	Core stage-wrapping with an explicit per-boundary PipelineVarPlan.
(package private) StageWrapResult	StreamStageDispatcher.wrapWithStages(List<EK9Parser.StreamPartContext> stages, List<IRInstr> innerBody, String pipelineItemVar, ISymbol elementType, DebugInfo debugInfo, List<StageState> stageStates, String asyncExecutorVar, PipelineVarPlan plan, String doneFlagVar)	Core stage-wrapping, additionally threading a doneFlagVar into a HEAD stage's else-branch.

Constructors in org.ek9lang.compiler.phase7.generator with parameters of type EK9Parser.StreamPartContext

Modifier	Constructor	Description
(package private)	StageWrapParams(EK9Parser.StreamPartContext stageCtx, List<IRInstr> innerBody, DebugInfo debugInfo)	Creates an instance of a StageWrapParams record class.

Constructor parameters in org.ek9lang.compiler.phase7.generator with type arguments of type EK9Parser.StreamPartContext

Modifier	Constructor	Description
(package private)	StageGroup(List<EK9Parser.StreamPartContext> stages, List<StageState> states)	Creates an instance of a StageGroup record class.

Uses of EK9Parser.StreamPartContext in org.ek9lang.compiler.support

Methods in org.ek9lang.compiler.support with parameters of type EK9Parser.StreamPartContext

Modifier and Type	Method	Description
StreamCallSymbol	StreamFactory.newStreamPart(EK9Parser.StreamPartContext ctx, IScope scope)	Create a new symbol that represents an EK9 stream function part of a stream pipeline.
StreamCallSymbol	SymbolFactory.newStreamPart(EK9Parser.StreamPartContext ctx, IScope scope)	Create a new symbol that represents an EK9 stream function part of a stream pipeline.