Last chance! 50% off unlimited learning
Sale ends in
Send data asynchronously over a connection (Socket, Context or Stream).
send_aio(con, data, mode = c("serial", "raw"), timeout = NULL)A 'sendAio' (object of class 'sendAio') (invisibly).
a Socket, Context or Stream.
an object (a vector, if mode = 'raw').
[default 'serial'] for sending serialised R objects, or 'raw' for sending vectors of any type (converted to a raw byte vector for sending). For Streams, 'raw' is the only option and this argument is ignored. Use 'serial' for perfect reproducibility within R, although 'raw' must be used when interfacing with external applications that do not understand R serialisation. Alternatively, for performance, specify an integer position in the vector of choices i.e. 1L for 'serial' or 2L for 'raw'.
[default NULL] integer value in milliseconds or NULL, which applies a socket-specific default, usually the same as no timeout.
Async send is always non-blocking and returns a 'sendAio' immediately.
For a 'sendAio', the send result is available at $result. An
'unresolved' logical NA is returned if the async operation is yet to
complete, The resolved value will be zero on success, or else an integer
error code.
To wait for and check the result of the send operation, use
call_aio on the returned 'sendAio' object.
Alternatively, to stop the async operation, use stop_aio.
pub <- socket("pub", dial = "inproc://nanonext")
res <- send_aio(pub, data.frame(a = 1, b = 2), timeout = 100)
res
res$result
res <- send_aio(pub, "example message", mode = "raw", timeout = 100)
call_aio(res)$result
close(pub)
Run the code above in your browser using DataLab