re-factor aio c code

Author: shikokuchuo

NEWS.md

@@ -4,7 +4,7 @@
 
 * New `stream()` interface exposes low-level byte stream functionality in the NNG library, intended for communicating with non-NNG endpoints, including but not limited to websocket servers.
 * `ncurl()` adds an 'async' option to perform HTTP requests asynchronously, returning immediately with a 'recvAio'. Also adds explicit arguments for HTTP method, headers (which takes a named list or character vector) and request data.
-* New `messenger()` function implements a console-based 2-way messaging system using NNG's scalability protocols [currently experimental and undergoing early-stage testing].
+* New `messenger()` function implements a console-based 2-way messaging system using NNG's scalability protocols [currently experimental and undergoing testing].
 
 #### Updates
 

R/aio.R

@@ -122,12 +122,14 @@ send_aio.nanoStream <- function(con, data, mode = "raw", timeout) {
   }
   env <- `class<-`(new.env(), "sendAio")
   result <- NULL
+  unresolv <- TRUE
   makeActiveBinding(sym = "result", fun = function(x) {
-    if (is.null(result)) {
+    if (unresolv) {
       res <- .Call(rnng_aio_result, aio)
       missing(res) && return(.Call(rnng_aio_unresolv))
       if (res) logerror(res)
       result <<- res
+      unresolv <<- FALSE
     }
     result
   }, env = env)
@@ -373,7 +375,7 @@ recv_aio.nanoStream <- function(con,
   if (keep.raw) {
     makeActiveBinding(sym = "raw", fun = function(x) {
       if (unresolv) {
-        res <- .Call(rnng_aio_stream_recv, aio)
+        res <- .Call(rnng_aio_stream_in, aio)
         missing(res) && return(.Call(rnng_aio_unresolv))
         is.integer(res) && {
           data <<- raw <<- `class<-`(res, "errorValue")
@@ -397,7 +399,7 @@ recv_aio.nanoStream <- function(con,
   }
   makeActiveBinding(sym = "data", fun = function(x) {
     if (unresolv) {
-      res <- .Call(rnng_aio_stream_recv, aio)
+      res <- .Call(rnng_aio_stream_in, aio)
       missing(res) && return(.Call(rnng_aio_unresolv))
       is.integer(res) && {
         data <<- raw <<- `class<-`(res, "errorValue")

R/messenger.R

@@ -19,7 +19,7 @@
 #'     \code{:q} is the command to quit.
 #'
 #'     NOTE: This is an experimental feature that is currently undergoing
-#'     early-stage testing.
+#'     testing.
 #'
 #' @export
 #'