A monad for orchestrating distributed computations via HIO.

Runs an Orc computation, discarding the (many) results of the computation. See collect on a mechanism for collecting the results of a computation into a list.

Collects all of the values of the computation p and delivers them as a list when p is completed.

Parallel choice operator that performs the actions of p and q and returns their results as they become available. Also written as |. There is no left-right bias: the ordering between p and q is unspecified.

An associative binary operation

Terminates an Orc computation.

Alternate phrasing of return (), which can be placed at the end of an Orc computation to signal that it has no more values to produce.

Biased choice operator ("and-then") that performs the action (and returns all the results) of p first, and then once done performs the actions of q.

A variant of <+> ("or-else") which performs and returns the results of p, and if p produced no answers continues to perform and return the results of q.

Cut executes an orc expression, waits for the first result, and then suppresses the rest, including killing any threads involved in computing the remainder.

An alternate mechanism for eagerly, it fires up a thread for p and returns a lazy thunk that contains the single (trimmed) result of the computation. Be careful to use this function with publish when these lazy values need to be fully evaluated before proceeding further.

Immediately fires up a thread for p, and then returns a handle to the first result of that thread which is also of type Orc a. An invocation of eagerly is non-blocking, while an invocation of the resulting handle is blocking.

Convenience function to print to stdout in an Orc computation.

Repeatedly reads values from the vals MVar until j values have been read or the vals MVar is exhausted (a Nothing is passed). When there are no more values to be returned, fills the end MVar.

Executes the computation p and done. Once done returns its first result, kill both computations and return that result. This discards the results of p.

Immediately executes the computation p, but if it hasn't returned a result in t seconds, executes the computation q and returns whichever computations returns a result first (kill the other thread).

Runs the computation p and returns its first result, but doesn't return before w seconds have elapsed.

Wait for a period of w seconds before continuing.

Publish is a hyperstrict form of return. It is usfeul for combining results from multiple val computations, providing a synchronization point.

Repeatedly executes the computation p and returns its results. repeating works best when p is single-valued: if p is multi-valued Orc will spawn a repeating thread for every result returned, resulting in an exponential blow-up of threads. NB: this behavior may not be intentional

Takes the first result of p, the first result of q, and applies them to f. The computations for p and q are run in parallel.

Runs the computation p and returns the first n results.

Drops the first n results of the computation p and then returns the rest of the results.

Zips the results of two computations p and q. When one computation finishes, kill the other.

Runs a list of Orc computations ps in parallel until they produce their first result, and returns a list of all these results.

Runs a computation p and writes its results to the channel ch.

Provided that the result type can be Shown, this prints the result of an Orc computation.

Convenience to solicit user input from stdin, via stdout.