.dispatcher_start

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 

Staysail Systems, Inc. 

Capitar IT Group BV 

The Mbed TLS Contributors 

Pierre L'Ecuyer

sakura authors 

R Consortium 

.dispatcher_start function

<dl><dt>url</dt>
<dd>URL to listen at for daemon connections.</dd>
<dt>disp_url</dt>
<dd>inproc:// URL for host REQ socket.</dd>
<dt>tls</dt>
<dd>TLS configuration or NULL.</dd>
<dt>serial</dt>
<dd>Serialization configuration (list or NULL).</dd>
<dt>stream</dt>
<dd>RNG stream integer vector (.Random.seed).</dd>
<dt>capacity</dt>
<dd>Memory budget in MB (metric, 1 MB = 1,000,000 bytes) for
queued task payloads. <code>NULL</code>, 0, non-finite, or negative values are
treated as unlimited.</dd>
<dt>cvar</dt>
<dd>Shared condition variable for capacity signaling.</dd></dl>

Arguments

Start In-Process Dispatcher — .dispatcher_start

<dl>

<dt>url</dt>
<dd>URL to listen at for daemon connections.</dd>


<dt>disp_url</dt>
<dd>inproc:// URL for host REQ socket.</dd>


<dt>tls</dt>
<dd>TLS configuration or NULL.</dd>


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


<dt>stream</dt>
<dd>RNG stream integer vector (.Random.seed).</dd>


<dt>capacity</dt>
<dd>Memory budget in MB (metric, 1 MB = 1,000,000 bytes) for
queued task payloads. <code>NULL</code>, 0, non-finite, or negative values are
treated as unlimited.</dd>


<dt>cvar</dt>
<dd>Shared condition variable for capacity signaling.</dd>

</dl>

Start In-Process Dispatcher

.dispatcher_start: Start In-Process Dispatcher

Description

Usage

Value

Arguments