Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  def +(other: String): String

   Implicit

   This member is added by an implicit conversion from AkkaExecutor to any2stringadd[AkkaExecutor] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

4.  def ->[B](y: B): (AkkaExecutor, B)

   Implicit

   This member is added by an implicit conversion from AkkaExecutor to ArrowAssoc[AkkaExecutor] performed by method ArrowAssoc in scala.Predef.

   Definition Classes

   ArrowAssoc

   Annotations

   @inline()

5.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  def call[H <: PiEventHandler[UUID]](instance: PiInstance[_], factory: PiEventHandlerFactory[UUID, H]): Future[H]

   A init ; start sequence that gives us a chance to subscribe a listener that is specific to this execution.

   A init ; start sequence that gives us a chance to subscribe a listener that is specific to this execution. A new ID will be generated for the PiInstance to ensure freshness.

   instance

   The PiInstance to be executed

   factory

   A PiEventHandlerFactory which generates PiEventHandler's for a given ID

   returns

   A Future with the PiEventHandler that was generated

   Definition Classes

   ProcessExecutor

8.  def call[H <: PiEventHandler[UUID]](process: PiProcess, args: Seq[Any], factory: PiEventHandlerFactory[UUID, H]): Future[H]

   A init ; start sequence that gives us a chance to subscribe a listener that is specific to this execution.

   A init ; start sequence that gives us a chance to subscribe a listener that is specific to this execution.

   process

   The (atomic or composite) PiProcess to be executed

   args

   The (real) arguments to be passed to the process

   factory

   A PiEventHandlerFactory which generates PiEventHandler's for a given ID

   returns

   A Future with the PiEventHandler that was generated

   Definition Classes

   ProcessExecutor

9.  def call(instance: PiInstance[_]): Future[UUID]

   A simple init ; start sequence when we do not need any even listeners.

   A simple init ; start sequence when we do not need any even listeners. A new ID will be generated for the PiInstance to ensure freshness.

   instance

   The PiInstance to be executed

   returns

   A Future with the ID corresponding to this execution

   Definition Classes

   ProcessExecutor

10.  def call(process: PiProcess, args: Seq[Any]): Future[UUID]

    A simple init ; start sequence when we do not need any even listeners.

    A simple init ; start sequence when we do not need any even listeners.

    process

    The (atomic or composite) PiProcess to be executed

    args

    The (real) arguments to be passed to the process

    returns

    A Future with the ID corresponding to this execution

    Definition Classes

    ProcessExecutor

11.  def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

12.  def ensuring(cond: (AkkaExecutor) ⇒ Boolean, msg: ⇒ Any): AkkaExecutor

    Implicit

    This member is added by an implicit conversion from AkkaExecutor to Ensuring[AkkaExecutor] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

13.  def ensuring(cond: (AkkaExecutor) ⇒ Boolean): AkkaExecutor

    Implicit

    This member is added by an implicit conversion from AkkaExecutor to Ensuring[AkkaExecutor] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

14.  def ensuring(cond: Boolean, msg: ⇒ Any): AkkaExecutor

    Implicit

    This member is added by an implicit conversion from AkkaExecutor to Ensuring[AkkaExecutor] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

15.  def ensuring(cond: Boolean): AkkaExecutor

    Implicit

    This member is added by an implicit conversion from AkkaExecutor to Ensuring[AkkaExecutor] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

16.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

17.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

18.  val execActor: ActorRef
19.  def execute(instance: PiInstance[_]): Future[Any]

    Executes a PiInstance with a PromiseHandler A new ID will be generated for the PiInstance to ensure freshness.

    Executes a PiInstance with a PromiseHandler A new ID will be generated for the PiInstance to ensure freshness.

    returns

    A Future with the result of the executed process

    Definition Classes

    ProcessExecutor

20.  def execute(process: PiProcess, args: Seq[Any]): Future[Any]

    Executes a process with a PromiseHandler

    Executes a process with a PromiseHandler

    returns

    A Future with the result of the executed process

    Definition Classes

    ProcessExecutor

21.  implicit val executionContext: ExecutionContext

    Definition Classes

    AkkaExecutor → ProcessExecutor

22.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

23.  def formatted(fmtstr: String): String

    Implicit

    This member is added by an implicit conversion from AkkaExecutor to StringFormat[AkkaExecutor] performed by method StringFormat in scala.Predef.

    Definition Classes

    StringFormat

    Annotations

    @inline()

24.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

25.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

26.  def init(instance: PiInstance[_]): Future[UUID]

    Initializes a PiInstance for a process execution.

    Initializes a PiInstance for a process execution. A new ID will be generated for the PiInstance to ensure freshness. This is always and only invoked before a start, hence why it is protected. This separation gives a chance to PiEventHandlers to subscribe before execution starts.

    instance

    The PiInstance to be executed

    returns

    A Future with the new unique ID that was generated

    Attributes

    protected

    Definition Classes

    AkkaExecutor → ProcessExecutor

27.  def init(process: PiProcess, args: Seq[PiObject]): Future[UUID]

    Initializes a PiProcess call for a process execution.

    Initializes a PiProcess call for a process execution. This is always and only invoked before a start, hence why it is protected. This separation gives a chance to PiEventHandlers to subscribe before execution starts.

    process

    The (atomic or composite) PiProcess to be executed

    args

    The PiObject arguments to be passed to the process

    returns

    A Future with the new unique ID that was generated

    Attributes

    protected

    Definition Classes

    ProcessExecutor

28.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

29.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

30.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

31.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

32.  val publisher: ActorRef

    Definition Classes

    AkkaExecutor → AkkaPiObservable

33.  def start(id: UUID): Unit

    Starts the execution of an initialized PiInstance.

    Starts the execution of an initialized PiInstance. This is always and only invoked after an init, hence why it is protected. This separation gives a chance to PiEventHandlers to subscribe before execution starts.

    id

    The ID of the instance to start executing

    Attributes

    protected

    Definition Classes

    AkkaExecutor → ProcessExecutor

34.  def subscribe(handler: PiEventHandler[UUID]): Future[PiSwitch]

    Subscribes a com.workflowfm.pew.stream.PiEventHandler to observe.

    Subscribes a com.workflowfm.pew.stream.PiEventHandler to observe.

    handler

    the handler to subscribe

    returns

    the com.workflowfm.pew.stream.PiSwitch that allows us to stop/unsubscribe the subscribed handler

    Definition Classes

    AkkaPiObservable → PiObservable

35.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

36.  implicit val system: ActorSystem

    Definition Classes

    AkkaExecutor → AkkaPiObservable

37.  implicit val timeout: FiniteDuration

    Definition Classes

    AkkaExecutor → AkkaPiObservable

38.  def toString(): String

    Definition Classes

    AnyRef → Any

39.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

40.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

41.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

42.  def →[B](y: B): (AkkaExecutor, B)

    Implicit

    This member is added by an implicit conversion from AkkaExecutor to ArrowAssoc[AkkaExecutor] performed by method ArrowAssoc in scala.Predef.

    Definition Classes

    ArrowAssoc