.flat

.progress

.progress_cli

.stop

Expressions to be provided to the <code>[]</code> method for &#8216;mirai_map&#8217;
objects, or the <code>...</code> argument of <code>collect_mirai</code>.

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)
ensure 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

Joe Cheng

Hibiki AI Limited 

Posit Software, PBC 

.flat function

An object of class <code>bytecode</code> of length 1.
An object of class <code>bytecode</code> of length 1.
An object of class <code>bytecode</code> of length 1.
An object of class <code>bytecode</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 simple text
progress indicator of parts completed of the total.
<code>x[.progress_cli]</code> collects map results whilst showing a progress bar
from the <a href="https://CRAN.R-project.org/package=cli">cli</a> package, if available, with completion percentage and
ETA.
<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 the manner of: 
<code>x[.stop, .progress]</code> which applies early stopping together with a
progress indicator.

Collection Options

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 simple text
progress indicator of parts completed of the total.
<code>x[.progress_cli]</code> collects map results whilst showing a progress bar
from the <a href='https://CRAN.R-project.org/package=cli'>cli</a> package, if available, with completion percentage and
ETA.
<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 the manner of: 
<code>x[.stop, .progress]</code> which applies early stopping together with a
progress indicator.

.flat: mirai Map Options

Description

Usage

Arguments

Format

Collection Options