.flat

.progress

.stop

Expressions to insert into the <code>[]</code> method for &#8216;mirai_map&#8217;
 objects.

datasets

internal

Designed for simplicity, a 'mirai' evaluates an R expression
asynchronously in a parallel process, locally or distributed over the
network, with the result automatically available upon completion. Modern
networking and concurrency built on 'nanonext' and 'NNG' (Nanomsg Next Gen)
ensures reliable and efficient scheduling, over fast inter-process
communications or TCP/IP secured by TLS. Advantages include being inherently
queued thus handling many more tasks than available processes, no storage on
the file system, support for otherwise non-exportable reference objects, an
event-driven promises implementation, and built-in asynchronous parallel
map.

Charlie Gao

mirai

Minimalist Async Evaluation Framework for R

Hibiki AI Limited 

.flat function

An object of class <code>expression</code> of length 1.
An object of class <code>expression</code> of length 1.
An object of class <code>expression</code> of length 1.

Format

<code>x[]</code> collects the results of a &#8216;mirai_map&#8217; <code>x</code> and
 returns a list. This will wait for all asynchronous operations to
 complete if still in progress, blocking but user-interruptible.
<code>x[.flat]</code> collects and flattens map results to a vector, checking
 that they are of the same type to avoid coercion. Note: errors if an
 &#8216;errorValue&#8217; has been returned or results are of differing type.
<code>x[.progress]</code> collects map results whilst showing a text progress
 indicator.
<code>x[.stop]</code> collects map results applying early stopping, which stops
 at the first failure and cancels remaining operations. Note: operations
 already in progress continue to completion, although their results are
 not collected.
The options above may be combined in a vector, for example: 
 <code>x[c(.stop, .progress)]</code> applies early stopping together with a
 progress indicator.

Results

mirai Map Options — .flat

<code>x[]</code> collects the results of a &#8216;mirai_map&#8217; <code>x</code> and
 returns a list. This will wait for all asynchronous operations to
 complete if still in progress, blocking but user-interruptible.
<code>x[.flat]</code> collects and flattens map results to a vector, checking
 that they are of the same type to avoid coercion. Note: errors if an
 &#8216;errorValue&#8217; has been returned or results are of differing type.
<code>x[.progress]</code> collects map results whilst showing a text progress
 indicator.
<code>x[.stop]</code> collects map results applying early stopping, which stops
 at the first failure and cancels remaining operations. Note: operations
 already in progress continue to completion, although their results are
 not collected.
The options above may be combined in a vector, for example: 
 <code>x[c(.stop, .progress)]</code> applies early stopping together with a
 progress indicator.

.flat: mirai Map Options

Description

Usage

Arguments

Format

Results