final case class Mapped[II, IO, IE, -OI, +OO, +OE](evolution: Evolution[II, IO, IE], f: (Stage[II, IO, IE]) => Stage[OI, OO, OE]) extends Evolution[OI, OO, OE] with Product with Serializable
An Evolution whose continuations are produced by applying f to the corresponding continuations of
evolution.
Created by Evolution#map. Disposal is delegated to the wrapped evolution.
- II
input type of the inner stages
- IO
output type of the inner stages
- IE
error type of the inner stages
- OI
input type of the resulting stages (contravariant)
- OO
output type of the resulting stages (covariant)
- OE
error type of the resulting stages (covariant)
- evolution
the inner evolution whose continuations are transformed
- f
the function applied to each continuation stage
- Source
- Evolution.scala
- Alphabetic
- By Inheritance
- Mapped
- Serializable
- Product
- Equals
- Evolution
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
Value Members
- final def !=(arg0: scala.Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: scala.Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def compose[_O, _E >: OE](that: Evolution[OO, _O, _E]): Evolution[OI, _O, _E]
Composes this evolution with another, creating a new evolution whose continuation for any status is the sequential composition of the corresponding continuations of both evolutions.
Composes this evolution with another, creating a new evolution whose continuation for any status is the sequential composition of the corresponding continuations of both evolutions.
Specifically:
composed(s) == self(s) ~> that(s)
Used internally when merging evolutions during Yield composition inside Stage.AndThen.
- _O
the output type of the resulting stages
- _E
the combined error type
- that
the downstream evolution to compose with
- returns
a new evolution representing
selffollowed bythat
- Definition Classes
- Evolution
- Annotations
- @inline()
- def dispose(): Unit
Releases all resources held by the Stage that produced this evolution.
Releases all resources held by the Stage that produced this evolution.
After this call the producing stage must be considered permanently unusable — it must not be applied or skipped again. This is the exclusive cleanup point for resources owned by the producing stage.
Called when the producing stage is permanently shut down:
- by Stage.execute after the pipeline has produced its terminal Outcome, so the continuation is released immediately rather than carried forward;
- when
applythrows aThrowable, since the stage can no longer be used and all its resources must still be released.
Implementations that hold no external resources may leave this as a no-op.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val evolution: Evolution[II, IO, IE]
- def evolve(status: Status[_]): Stage[OI, OO, OE]
Returns the next Stage based on the given
status.Returns the next Stage based on the given
status.May release resources that are specific to this evolution instance and will not be reused by subsequent generations (i.e. resources not needed by the returned stage or its own evolution).
- status
the status that determines the continuation stage
- val f: (Stage[II, IO, IE]) => Stage[OI, OO, OE]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def map[_I, _O, _E](f: (Stage[OI, OO, OE]) => Stage[_I, _O, _E]): Evolution[_I, _O, _E]
Transforms every continuation of this evolution by applying
fto the stage it returns.Transforms every continuation of this evolution by applying
fto the stage it returns.This is the public API for adapting an
Evolutionto a different stage type without exposing internal composition details.- _I
the input type of the resulting stages
- _O
the output type of the resulting stages
- _E
the error type of the resulting stages
- f
a function that transforms each continuation stage
- returns
a new evolution with all continuations mapped by
f
- Definition Classes
- Evolution
- Annotations
- @inline()
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)