race_aio

Returns the index of the first resolved Aio in a list, waiting if necessary.

R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ.
A toolkit for messaging, concurrency and the web. High-performance
socket messaging over in-process, IPC, TCP, WebSocket and secure TLS
transports implements 'Scalability Protocols', a standard for common
communications patterns including publish/subscribe, request/reply and
survey. A threaded concurrency framework with intuitive 'aio' objects
that resolve automatically upon completion of asynchronous operations,
and synchronisation primitives that allow R to wait on events
signalled by concurrent threads. A unified HTTP server hosting REST
endpoints, WebSocket connections and streaming on a single port, with
a built-in HTTP client.

Charlie Gao

nanonext

Lightweight Toolkit for Messaging, Concurrency and the Web

Posit Software, PBC 

Hibiki AI Limited 

R Consortium 

race_aio function

<dl><dt>x</dt>
<dd>A list of Aio objects.</dd>
<dt>cv</dt>
<dd>A condition variable. This must be the same cv supplied to
<code>recv_aio()</code> or <code>request()</code> when creating the Aio objects in <code>x</code>.</dd></dl>

Arguments

Race Aio — race_aio

<dl>

<dt>x</dt>
<dd>A list of Aio objects.</dd>


<dt>cv</dt>
<dd>A condition variable. This must be the same cv supplied to
<code>recv_aio()</code> or <code>request()</code> when creating the Aio objects in <code>x</code>.</dd>

</dl>

race_aio: Race Aio

Description

Usage

Value

Arguments