.dispatcher

Run the dispatcher event loop for mirai task distribution.

internal

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 

.dispatcher function

<dl><dt>sock</dt>
<dd>REP socket for host communication.</dd>
<dt>psock</dt>
<dd>POLY socket for daemon communication.</dd>
<dt>monitor</dt>
<dd>Monitor object for pipe events (its CV is used for signaling).</dd>
<dt>reset</dt>
<dd>Pre-serialized connection reset error (raw vector).</dd>
<dt>serial</dt>
<dd>Serialization configuration (list or NULL).</dd>
<dt>envir</dt>
<dd>Environment containing RNG stream state.</dd>
<dt>next_stream</dt>
<dd>Function to get next RNG stream, called as next_stream(envir).</dd></dl>

Arguments

Dispatcher — .dispatcher

<dl>

<dt>sock</dt>
<dd>REP socket for host communication.</dd>


<dt>psock</dt>
<dd>POLY socket for daemon communication.</dd>


<dt>monitor</dt>
<dd>Monitor object for pipe events (its CV is used for signaling).</dd>


<dt>reset</dt>
<dd>Pre-serialized connection reset error (raw vector).</dd>


<dt>serial</dt>
<dd>Serialization configuration (list or NULL).</dd>


<dt>envir</dt>
<dd>Environment containing RNG stream state.</dd>


<dt>next_stream</dt>
<dd>Function to get next RNG stream, called as next_stream(envir).</dd>

</dl>

.dispatcher: Dispatcher

Description

Usage

Value

Arguments