Uses of Record Class
org.ek9lang.compiler.phase7.generator.IteratorSetup
Packages that use IteratorSetup
-
Uses of IteratorSetup in org.ek9lang.compiler.phase7.generator
Methods in org.ek9lang.compiler.phase7.generator that return IteratorSetupModifier and TypeMethodDescription(package private) IteratorSetupStreamPipelineMachinery.drainSourceToIterator(String sourceVar, String sourceTypeName, String hasNextMethod, String nextMethod, CallDetails closeCall, ISymbol bucketType, DebugInfo debugInfo, List<IRInstr> instructions) MATERIALISE a buffering value source (a GROUP/SPLIT tracker's hasNextGroup/nextGroup, or an async executor's hasNext/next) into a fresh raw EK9_LIST buffer and return an IteratorSetup over it.SortAndIteratorResult.iteratorSetup()Returns the value of theiteratorSetuprecord component.SortSetup.iteratorSetup()Returns the value of theiteratorSetuprecord component.StreamSource.iteratorSetup()Returns the value of theiteratorSetuprecord component.Methods in org.ek9lang.compiler.phase7.generator with parameters of type IteratorSetupModifier and TypeMethodDescription(package private) SortSetupStreamEmissionEngine.applySortToCollection(List<EK9Parser.StreamPartContext> stages, IteratorSetup iteratorSetup, ISymbol elementType, IAggregateSymbol collectionType, DebugInfo debugInfo, List<IRInstr> instructions, boolean sourceUnbounded) (package private) voidStreamEmissionEngine.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 casecat udp | async | filter | head N | collect).(package private) ConditionAndPostLoopStreamPipelineMachinery.buildStreamLoop(IteratorSetup iteratorSetup, StageState headState, String itemVar, ISymbol itemType, boolean rawIterator, EK9Parser.StreamCatContext catCtx, StreamLoopSink sink, DebugInfo debugInfo) The unified iterator-driven stream while-loop skeleton: condition scope (hasNext(), with an optionalheadshort-circuit folded in whenheadState != null) + body scope (binditerator.next()then theStreamLoopSinkbody-tail) + theConditionAndPostLoopthe caller feeds tocreateWhileLoop.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) voidStreamEmissionEngine.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 assourceIterthroughstagesto the terminal, with NO composition limit.(package private) ConditionAndPostLoopStreamEmissionEngine.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).Constructors in org.ek9lang.compiler.phase7.generator with parameters of type IteratorSetupModifierConstructorDescription(package private)SortAndIteratorResult(List<IRInstr> instructions, IteratorSetup iteratorSetup) Creates an instance of aSortAndIteratorResultrecord class.(package private)SortSetup(IteratorSetup iteratorSetup, int sortIndex) Creates an instance of aSortSetuprecord class.(package private)StreamSource(IteratorSetup iteratorSetup, ISymbol elementType, boolean sourceUnbounded) Creates an instance of aStreamSourcerecord class.