nanonext (version 0.1.0)

ctx_send_vec: Send Vector over Context (Async)

Description

Send any number of R vectors asynchronously over a Context, with the ability to set (optional) send timeouts. Data will be sent as binary without R serialisation, hence appropriate for interfacing with external programs.

Usage

ctx_send_vec(context, ..., timeout)

Arguments

context

a Context.

...

one or more R objects to send (serialised) asynchronously.

timeout

in ms. If unspecified, a socket-specific default timeout will be used.

Value

A vector of zeros (invisibly) on success.

Details

Will block if the send is in progress and has not yet completed - certain protocol / transport combinations may limit the number of messages that can be queued if they have yet to be received. Set a timeout to ensure the function returns under all conditions.

Examples

# NOT RUN {
req <- socket("req", listen = "inproc://nanonext")
rep <- socket("rep", dial = "inproc://nanonext")

ctx <- context(req)
out <- ctx_send_vec(ctx, c(1.1, 2.2), c(3.3, 4.4), timeout = 1000)
out

close(req)
close(rep)

# }