trait USD2NOK extends (PriceUSD) ⇒ Future[PriceNOK] with AtomicProcess
- Alphabetic
- By Inheritance
- USD2NOK
- AtomicProcess
- MetadataAtomicProcess
- PiProcess
- Function1
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
Concrete 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): (USD2NOK, B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
lazy val
actualChannels: Seq[Chan]
- Attributes
- protected
- Definition Classes
- PiProcess
-
lazy val
allDependencies: Seq[PiProcess]
- Definition Classes
- PiProcess
-
def
andThen[A](g: (Future[PriceNOK]) ⇒ A): (PriceUSD) ⇒ A
- Definition Classes
- Function1
- Annotations
- @unspecialized()
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- val channels: Seq[String]
-
implicit
def
chansFromStringSeq(s: Seq[String]): Seq[Chan]
- Definition Classes
- PiProcess
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
compose[A](g: (A) ⇒ PriceUSD): (A) ⇒ Future[PriceNOK]
- Definition Classes
- Function1
- Annotations
- @unspecialized()
-
val
dependencies: Seq[PiProcess]
- Definition Classes
- MetadataAtomicProcess → PiProcess
- def ensuring(cond: (USD2NOK) ⇒ Boolean, msg: ⇒ Any): USD2NOK
- def ensuring(cond: (USD2NOK) ⇒ Boolean): USD2NOK
- def ensuring(cond: Boolean, msg: ⇒ Any): USD2NOK
- def ensuring(cond: Boolean): USD2NOK
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
execState(args: Seq[PiObject]): PiState
Initializes a PiState that executes this process with a given list of PiObject arguments.
Initializes a PiState that executes this process with a given list of PiObject arguments. Generates an Output term from each PiObject in args so that they can be fed to the process. Also generates an Input that consumes the output of the process when it is done. Adds all dependencies to the state and then runs a PiCall directly.
- Definition Classes
- PiProcess
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getFuture(i: Int, args: Chan*): PiFuture
- Definition Classes
- MetadataAtomicProcess
-
def
getFuture(i: Int, m: ChanMap): PiFuture
This constructs a PiFuture to be added to the state when the process is called.
This constructs a PiFuture to be added to the state when the process is called.
- Definition Classes
- MetadataAtomicProcess
-
def
getInputs(i: Int, args: Chan*): Seq[Input]
- Definition Classes
- MetadataAtomicProcess
-
def
getInputs(i: Int, m: ChanMap): Seq[Input]
This constructs the Input terms needed to appopriately receive the process inputs.
This constructs the Input terms needed to appopriately receive the process inputs.
- Definition Classes
- MetadataAtomicProcess
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
iname: String
- Definition Classes
- PiProcess
-
def
inputFrees(): Seq[Seq[Chan]]
- Definition Classes
- PiProcess
- val inputs: Seq[(Chan, String)]
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
mapArgs(args: Chan*): ChanMap
Used when a process is called to map argument channels to the given values.
Used when a process is called to map argument channels to the given values.
- Definition Classes
- PiProcess
-
def
mapFreshArgs(i: Int, args: Chan*): ChanMap
- Definition Classes
- PiProcess
- val name: String
-
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 output: (Chan, String)
-
def
run(args: Seq[PiObject])(implicit ec: ExecutionContext): Future[PiObject]
- Definition Classes
- USD2NOK → AtomicProcess
-
def
runMeta(args: Seq[PiObject])(implicit ec: ExecutionContext): Future[MetadataAtomicResult]
Implements the standard AtomicProcess interface for unsupporting ProcessExecutors.
Implements the standard AtomicProcess interface for unsupporting ProcessExecutors.
- returns
A future containing the result of the result as a PiObject and optional meta-data.
- Definition Classes
- AtomicProcess → MetadataAtomicProcess
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toEntry: (String, PiProcess)
Shortcut to create entries in name->PiProcess maps
Shortcut to create entries in name->PiProcess maps
- Definition Classes
- PiProcess
-
def
toIEntry: (String, PiProcess)
* Shortcut to create entries in name->PiProcess maps using the instance name
* Shortcut to create entries in name->PiProcess maps using the instance name
- Definition Classes
- PiProcess
-
def
toString(): String
- Definition Classes
- PiProcess → AnyRef → Any
-
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): (USD2NOK, B)