net.sf.asyncobjects.asyncscala
The resolver type
Expression variant of "all" operator
Expression variant of "all" operator
the asynchronous expression to be evaluated
the asynchronous expression to be evaluated
the asynchronous expression to be evaluated
the asynchronous expression to be evaluated
a promise for tuple value
Expression variant of "all" operator
Expression variant of "all" operator
the asynchronous expression to be evaluated
the asynchronous expression to be evaluated
the asynchronous expression to be evaluated
a promise for tuple value
Expression variant of "all" operator
Expression variant of "all" operator
the asynchronous expression to be evaluated
the asynchronous expression to be evaluated
a promise for tuple value
Start building All construct
Start building All construct
the body of the first branch
Start allFor creation
Start allFor creation
the collection of items
the body that translates individual items
the builder that allows specifying a folding rule
Construct list for each element of collection in iteration order
Construct list for each element of collection in iteration order
the collection of items
the body that translates individual items
the promise for list with all items
Construct a unit value when all activities finish.
Construct a unit value when all activities finish. This is the simplest variant of all construct
the collection of items
the body that translates individual items
the promise for unit that resolves when all activities finish
Start building any construct
Start building any construct
the first body
any construct builder
Create a already resolved promise with a failure outcome
Create a already resolved promise with a failure outcome
the problem for the failure
the resolved promise
Execute body
later in the specified vat
Execute body
later in the specified vat
the destination vat
the promise for execution results
Execute body
later in the current vat
Execute body
later in the current vat
the promise for execution results
Execute body
later in the specified vat
Execute body
later in the specified vat
the destination vat
the promise for execution results
Execute body
later in the current vat
Execute body
later in the current vat
the body to execute
the promise for execution results
a promise that will never resolve
Execute action in the current turn, and if there is a exception thrown, wrap into promise.
Execute action in the current turn, and if there is
a exception thrown, wrap into promise. Also null result
is considered as NullPointerException
. The operation
ensures that returned promise is valid, and there is no unexpected
exceptions.
the body of the action
the promise for body execution result
Execute body with resolver of returned promise ignoring result with except for thrown exception.
Execute body with resolver of returned promise ignoring result with except for thrown exception. The promise is supposed to be eventually resolved using the supplied resolver.
a promise that is resolved by body through resolver
Wrap result of function execution into promise
Wrap result of function execution into promise
the body to execute
the resolved promise that contain execution result
Start building Par construct
Start building Par construct
the body of the first branch
Start ParFor creation
Start ParFor creation
the collection of items
the body that translates individual items
the builder that allows specifying a folding rule
Construct list for each element of collection in iteration order, each item is iterated in new vat
Construct list for each element of collection in iteration order, each item is iterated in new vat
the collection of items
the body that translates individual items
the promise for list with all items
Construct a unit value when all activities finish in the vats.
Construct a unit value when all activities finish in the vats. This is the simplest variant of all construct
the collection of items
the body that translates individual items
the promise for unit that resolves when all activities finish
Create an exported resolver instance
Create an exported resolver instance
the resolver body
an exported instance of the resolver
Send an action to execute to the specified vat
Send an action to execute to the specified vat
the action to execute
Send an action to execute to the specified vat
Send an action to execute to the specified vat
the destination vat
the action to execute
The two argument seq that just orders two calls.
The two argument seq that just orders two calls. It does not work as expected SI-4657
the first body
the second body
the promise that resolves when second body resolves after the first (the result of the first is passed to second)
Start building seq operation
Start building seq operation
the body of operation
a constructor for when operation
The two argument seq that just orders two calls.
The two argument seq that just orders two calls. It does not work as expected SI-4657
the first body
the second body
the promise that resolves when second body resolves after the first (the result of the first is passed to second)
The two argument seq that just orders two calls.
The two argument seq that just orders two calls. It practically identical to aWhenLast(p1)(body2(_)), except that it might execute body2 on the same turn, if result is already available.
the first body
the second body
the promise that resolves when second body resolves after the first (the result of the first is passed to second)
A loop over collections that returns a unit as result of iteration
A loop over collections that returns a unit as result of iteration
the collection to iterate
the body of iteration
A loop over collections that returns a unit as result of iteration
A loop over collections that returns a unit as result of iteration
the collection to iterate
the body of iteration
A loop over collections that returns a unit as result of iteration
A loop over collections that returns a unit as result of iteration
the collection to iterate
A loop over collections that returns a unit as result of iteration
A loop over collections that returns a unit as result of iteration
the collection to iterate
the body of iteration
The two argument seq that just orders calls (the both arguments could be invoked on the same turn)
The two argument seq that just orders calls (the both arguments could be invoked on the same turn)
the first body
the second body
the promise that resolves when second body resolves after the first
The two argument seq that just orders calls (the both arguments could be invoked on the same turn)
The two argument seq that just orders calls (the both arguments could be invoked on the same turn)
the first body
the second body
the promise that resolves when second body resolves after the first
A simple loop that repeats body until body's promise resolves to false.
A simple loop that repeats body until body's promise resolves to false. The iteration starts on this turn, the next iterations are done on separate turns.
the body to repeat
the promise that resolves after last iteration
A sequence while construct that return unit
A sequence while construct that return unit
the condition
the body of the loop
the promise that resolves when looping finishes
Create a already resolved promise with a successful outcome
Create a already resolved promise with a successful outcome
the value that will be and outcome of the operation
the resolved promise
Return a unit promise
Start building when operation
Start building when operation
the input promise
the body of operation
Start building when operation (ignore result value of input promise)
Start building when operation (ignore result value of input promise)
the input promise
the body of operation
Start and finish building when operation (used when When#failed
and When#finallyDo
are not needed.
Start and finish building when operation (used when When#failed
and When#finallyDo
are not needed.
the input promise
the body of operation
Start building when operation (ignore result value of input promise)
Start building when operation (ignore result value of input promise)
the input promise
the body of operation
Start asynchronous context in the current thread.
Start asynchronous context in the current thread. The method starts a vats.SingleThreadRunner
in the current tread, and exits with the body's outcome when promise returned from body is resolved.
the body to execute
a value from body
Notify resolver with the specified failure
Notify resolver with the specified failure
the resolver to notify
the problem to notify with
The resolver that just does nothing
Notify resolver with the specified outcome.
Notify resolver with the specified outcome. The exceptions are logged
the resolver to notify
the operation outcome
Notify resolver with the specified value
Notify resolver with the specified value
the resolver to notify
a value of operation
Asynchronous control structures