implicit final class StageOps[I, O, E] extends AnyVal
Extension methods for Stage.
- Alphabetic
- By Inheritance
- StageOps
- AnyVal
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
##(): Int
- Definition Classes
- Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
execute(in: I): Outcome[O, E]
Executes this stage end-to-end and returns a plain Outcome.
Executes this stage end-to-end and returns a plain Outcome.
This is the reference terminal driver of the pipeline model. Internally this method:
- Applies the stage to
in, obtaining ah8io.stages.Yield. - Disposes the
h8io.stages.Evolutioncarried by theYield— sinceexecuteis a terminal operation, the continuation is not needed and the resources held by the stage must be released immediately. - Wraps the result in an Outcome.Some or Outcome.None.
Disposal failures do not prevent the result from being returned. Any non-fatal exception raised by
h8io.stages.Evolution.disposeis captured in Outcome.disposeFailure and the outcome is still produced. Fatal exceptions are not caught and will propagate.- in
the input value
- returns
Outcome.Some if this stage produced an output, Outcome.None otherwise
- Applies the stage to
-
def
getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val stage: Stage[I, O, E]
-
def
toEvolution(dispose: () ⇒ Unit): ConstEvolution[I, O, E]
Lifts this stage into a ConstEvolution that returns it for every status branch and runs
disposewhen disposed.Lifts this stage into a ConstEvolution that returns it for every status branch and runs
disposewhen disposed.The overload to reach for whenever the lifted stage is not the owner of what has to be released — an operator keeping the inner evolution as the cleanup handle of the generation it has just built, or a stage recovering from an exception with resources still to free.
- dispose
the thunk
h8io.stages.Evolution.disposedelegates to
- Annotations
- @inline()
-
def
toEvolution: Evolution[I, O, E]
Lifts this stage into a ConstEvolution that returns it for every status branch.
Lifts this stage into a ConstEvolution that returns it for every status branch.
Useful inside the
h8io.stages.cyclesoperators (h8io.stages.cycles.Loop, h8io.stages.cycles.Repeat, h8io.stages.cycles.Reduce and h8io.stages.cycles.Fold) to produce the evolution embedded in aYield.- Annotations
- @inline()
-
def
toString(): String
- Definition Classes
- Any