document

Author: shikokuchuo

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: nanonext
 Type: Package
 Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
-Version: 0.13.6.9000
+Version: 0.13.6.9002
 Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is
     a socket library implementing 'Scalability Protocols', a reliable,
     high-performance standard for common communications patterns including

NAMESPACE

@@ -75,7 +75,7 @@ export(recv_aio)
 export(recv_aio_signal)
 export(reply)
 export(request)
-export(request_promise)
+export(request2)
 export(request_signal)
 export(send)
 export(send_aio)

NEWS.md

@@ -1,4 +1,7 @@
-# nanonext 0.13.6 (development)
+# nanonext 0.13.6.9002 (development)
+
+* Integrates with the `later` package to provide the foundation for truly event-driven (non-polling) promises (thanks @jcheng5 for the initial prototype in #28), where side-effects are enacted asynchronously upon aio completion.
+* Adds `request2()` for creating a request that may be turned into an event-driven promise.
 
 # nanonext 0.13.6
 

R/context.R

@@ -270,14 +270,20 @@ request_signal <- function(context,
                            timeout = NULL)
   data <- .Call(rnng_request_signal, context, data, cv, send_mode, recv_mode, timeout, environment())
 
+#' Request2 (RPC Client for Req/Rep Protocol)
+#'
+#' \strong{request2} is the next generation request function that optionally
+#'     takes a condition variable for signalling, and supports event-driven
+#'     promises.
+#'
 #' @rdname request
 #' @export
 #'
-request_promise <- function(context,
-                            data,
-                            cv,
-                            send_mode = c("serial", "raw", "next"),
-                            recv_mode = c("serial", "character", "complex", "double",
-                                          "integer", "logical", "numeric", "raw", "string"),
-                            timeout = NULL)
+request2 <- function(context,
+                     data,
+                     cv = NULL,
+                     send_mode = c("serial", "raw", "next"),
+                     recv_mode = c("serial", "character", "complex", "double",
+                                   "integer", "logical", "numeric", "raw", "string"),
+                     timeout = NULL)
   data <- .Call(rnng_request_promise, context, data, cv, send_mode, recv_mode, timeout, environment())