case class PiFuture(fun: String, outChan: Chan, args: Seq[PiResource]) extends Product with Serializable
Represents a pending call to an atomic process in 2 situations: 1) A call has been encountered in the workflow, but we are waiting for the inputs to arrive. 2) The inputs have arrived, we have made the call to the actual process, and we are waiting for it to return.
- fun
the name of the process
- outChan
the channel through which we should send the output when it arrives
- args
the process inputs, each including a pattern of the input and the corresponding channel it will arrive through
- Alphabetic
- By Inheritance
- PiFuture
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
PiFuture(fun: String, outChan: Chan, args: Seq[PiResource])
- fun
the name of the process
- outChan
the channel through which we should send the output when it arrives
- args
the process inputs, each including a pattern of the input and the corresponding channel it will arrive through
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (PiFuture, B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val args: Seq[PiResource]
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def ensuring(cond: (PiFuture) ⇒ Boolean, msg: ⇒ Any): PiFuture
- def ensuring(cond: (PiFuture) ⇒ Boolean): PiFuture
- def ensuring(cond: Boolean, msg: ⇒ Any): PiFuture
- def ensuring(cond: Boolean): PiFuture
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
execute(m: ChanMap): Option[PiFuture]
We call this to check if all inputs have arrived and we can execute the process.
We call this to check if all inputs have arrived and we can execute the process.
- returns
an instantiated instance where all inputs are ground so we can make the call to the actual process, or None if not all inputs have arrived
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
- val fun: String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val outChan: Chan
- def sub(s: ChanMap): PiFuture
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toOutput(res: PiObject): Output
We call this once the process output has arrived, to create the appropriate Output pi-calculus term.
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def →[B](y: B): (PiFuture, B)