case class Execution(run: Option[(Env) => Future[() => Result]] = None, executing: Executing = NotExecuting, timeout: Option[FiniteDuration] = None, mustJoin: Boolean = false, nextMustStopIf: (Result) => Boolean = (r: Result) => false, isolable: Boolean = true, previousResult: Option[Result] = None, continuation: Option[FragmentsContinuation] = None) extends Product with Serializable

Execution of a Fragment

  • there can be none (for a piece of text)
  • the execution depends on the current Env. by default executions are created synchronously but can also be fork-off with Execution.withEnvAsync
  • it can have its own timeout (default is infinite)
  • once executed the result is kept
  • if mustJoin is true this means that all previous executions must be finished before this one can start
  • it has a condition deciding if the next execution can proceed or not depending on the current result
  • if isolable is true this means that it should be executed in its own specification instance
  • the result of a similar execution can be stored to decide if this one needs to be executed or not
  • it can store a continuation that will create more fragments, possibly containing more executions, based on the current result
Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Execution
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Execution(run: Option[(Env) => Future[() => Result]] = None, executing: Executing = NotExecuting, timeout: Option[FiniteDuration] = None, mustJoin: Boolean = false, nextMustStopIf: (Result) => Boolean = (r: Result) => false, isolable: Boolean = true, previousResult: Option[Result] = None, continuation: Option[FragmentsContinuation] = None)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def after(executions: List[Execution]): Execution

    run this execution after the previous executions are finished

  5. def afterSequential(executions: List[Execution]): Execution

    run this execution after the other executions have been sequentially executed

  6. def afterSuccessful(executions: List[Execution]): Execution

    run this execution after the executions and only if they are successful

  7. def afterSuccessfulSequential(executions: List[Execution]): Execution

    run this execution after the other executions have been sequentially executed and only if they are successful

  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  10. val continuation: Option[FragmentsContinuation]
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(a: Any): Boolean
    Definition Classes
    Execution → Equals → AnyRef → Any
  13. lazy val executedResult: TimedFuture[ExecutedResult]
  14. val executing: Executing
  15. lazy val executionResult: TimedFuture[Result]
  16. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  17. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. def hashCode(): Int
    Definition Classes
    Execution → AnyRef → Any
  19. def isExecutable: Boolean

    returns

    true if something can be run

  20. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  21. val isolable: Boolean
  22. def join: Execution

    methods to set the execution

  23. def makeGlobal(when: Boolean): Execution
  24. def makeGlobal: Execution
  25. def mapMessage(f: (String) => String): Execution

    force a message

  26. def mapResult(f: (Result) => Result): Execution

    force a result

  27. val mustJoin: Boolean
  28. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  29. val nextMustStopIf: (Result) => Boolean
  30. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  32. val previousResult: Option[Result]
  33. def productElementNames: Iterator[String]
    Definition Classes
    Product
  34. val run: Option[(Env) => Future[() => Result]]
  35. def setErrorAsFatal: Execution
  36. def setExecuting(r: Future[(Result, SimpleTimer)]): Execution

    returns

    set an execution result being computed

  37. def setFatal(f: Throwable): Execution

    returns

    set a fatal execution error

  38. def setPreviousResult(r: Option[Result]): Execution
  39. def setResult(r: => Result): Execution

    returns

    set an execution result

  40. def setTimeout(timeout: FiniteDuration): Execution
  41. def skip: Execution
  42. def startAfter(others: List[Execution])(env: Env): Execution

    start this execution when the other ones are finished

  43. def startAfter(other: Execution)(env: Env): Execution

    start this execution when the other one is finished

  44. def startExecution(env: Env): Execution

    run the execution

  45. def stopNextIf(f: (Result) => Boolean): Execution
  46. def stopNextIf(r: Result): Execution
  47. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  48. val timeout: Option[FiniteDuration]
  49. def toString(): String
    Definition Classes
    Execution → AnyRef → Any
  50. def updateResult(newResult: (=> Result) => Result): Execution
  51. def updateRun(newRun: ((Env) => Future[() => Result]) => (Env) => Future[() => Result]): Execution
  52. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  53. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  54. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  55. def was(statusCheck: (String) => Boolean): Boolean

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped