.flat

.progress

.stop

Expressions to be provided to the <code>[]</code> method for 'mirai_map' objects.

datasets

internal

Designed for simplicity, a 'mirai' evaluates an R expression
asynchronously in a parallel process, locally or distributed over the
network. The result is 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. Distributed computing can launch
remote resources via SSH or cluster managers. An inherently queued
architecture handles many more tasks than available processes, and requires
no storage on the file system. Innovative features include support for
otherwise non-exportable reference objects, event-driven promises, and
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.

Format

<code>x[]</code> collects the results of a 'mirai_map' <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 'errorValue'
has been returned or results are of differing type.
<code>x[.progress]</code> collects map results whilst showing a progress bar from
the <a href="https://CRAN.R-project.org/package=cli">cli</a> package, if installed, with completion percentage and ETA,
or else a simple text progress indicator. Note: if the map operation
completes too quickly then the progress bar may not show at all.
<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 'mirai_map' <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 'errorValue'
has been returned or results are of differing type.
<code>x[.progress]</code> collects map results whilst showing a progress bar from
the <a href='https://CRAN.R-project.org/package=cli'>cli</a> package, if installed, with completion percentage and ETA,
or else a simple text progress indicator. Note: if the map operation
completes too quickly then the progress bar may not show at all.
<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