Documentation

Converts a list of pure values into a transient task set. You can use the threads primitive to control the parallelism.

Same as choose, slower in some cases

transmit the end of stream

Collect the results of a task set, grouping all results received within every time interval specified by the first parameter as diffUTCTime.

Collect the results of the first n tasks. Synchronizes concurrent tasks to collect the results safely and kills all the non-free threads before returning the results. Results are returned in the thread where collect is called.

Like collect but with a timeout. When the timeout is zero it behaves exactly like collect. If the timeout (second parameter) is non-zero, collection stops after the timeout and the results collected till now are returned.

Collect the results of a task set in groups of n elements.