Prof Brian Ripley comments

Author: shikokuchuo

DESCRIPTION

@@ -19,7 +19,7 @@ License: GPL (>= 3)
 BugReports: https://github.com/shikokuchuo/nanonext/issues
 URL: https://shikokuchuo.net/nanonext/, https://github.com/shikokuchuo/nanonext/
 Encoding: UTF-8
-SystemRequirements: libnng or cmake
+SystemRequirements: either 'libnng' (deb: libnng-dev, rpm: nng-devel) or 'cmake' (to compile from source)
 Depends: 
     R (>= 2.4)
 RoxygenNote: 7.1.2

README.Rmd

@@ -35,7 +35,7 @@ Install the latest release from CRAN:
 install.packages("nanonext")
 ```
 
-or the latest development version from rOpenSci R-universe:
+or the development version from rOpenSci R-universe:
 
 ```{r runiv, eval=FALSE}
 install.packages("nanonext", repos = "https://shikokuchuo.r-universe.dev")

README.md

@@ -36,7 +36,7 @@ Install the latest release from CRAN:
 install.packages("nanonext")
 ```
 
-or the latest development version from rOpenSci R-universe:
+or the development version from rOpenSci R-universe:
 
 ``` r
 install.packages("nanonext", repos = "https://shikokuchuo.r-universe.dev")

tests/tests.R

@@ -9,7 +9,7 @@ invisible(inherits(n$socket, "nano") || stop())
 invisible(is.integer(attr(n$socket, "id")) || stop())
 invisible(n$socket$state == "opened" || stop())
 invisible(n$socket$protocol == "req" || stop())
-invisible(n$socket_setopt("ms", "req:resend-time", 2000) == 0 || stop())
+invisible(n$socket_setopt("ms", "req:resend-time", 1000) == 0 || stop())
 
 invisible(inherits(n$listener[[1]], "nanoListener") || stop())
 invisible(n$listener[[1]]$url == "inproc://nanonext" || stop())
@@ -21,25 +21,29 @@ invisible(n$listener[[1]]$state == "started" || stop())
 invisible(inherits(n1$dialer[[1]], "nanoDialer") || stop())
 invisible(n1$dialer[[1]]$url == "inproc://nanonext" || stop())
 invisible(n1$dialer[[1]]$state == "not started" || stop())
-invisible(n1$dialer_setopt("ms", "reconnect-time-min", 2000) == 0 || stop())
+invisible(n1$dialer_setopt("ms", "reconnect-time-min", 1000) == 0 || stop())
 invisible(suppressMessages(n1$dialer_start()) == 0L || stop())
 invisible(n1$dialer[[1]]$state == "started" || stop())
 
-suppressMessages(n$send_aio(data.frame(), timeout = 1000))
+suppressMessages(n$send_aio(data.frame(), timeout = 500))
 invisible(suppressMessages(n1$recv()))
-suppressMessages(n1$send_vec_aio("test reply", timeout = 1000))
+suppressMessages(n1$send_vec_aio("test reply", timeout = 500))
 invisible(suppressMessages(n$recv_vec("character")))
 
-n$dial(url = "inproc://two", autostart = FALSE)
+suppressMessages(n$dial(url = "inproc://two", autostart = TRUE))
 invisible(inherits(n$dialer[[1L]], "nanoDialer") || stop())
+suppressMessages(n$listen(url = "inproc://three"))
+invisible(inherits(n$listener[[2L]], "nanoListener") || stop())
 
 ctx <- context(n$socket)
 invisible(inherits(ctx, "nanoContext") || stop())
 invisible(inherits(ctx, "nano") || stop())
 invisible(is.integer(ctx$id) || stop())
 invisible(ctx$state == "opened" || stop())
 invisible(ctx$protocol == "req" || stop())
-invisible(setopt(ctx, "ms", "send-timeout", 2000) == 0 || stop())
+invisible(setopt(ctx, "ms", "send-timeout", 1000) == 0 || stop())
+suppressMessages(ctx_send(ctx, data.frame(), timeout = 500))
+suppressMessages(ctx_send_vec(ctx, "context test", timeout = 500))
 invisible(suppressMessages(close(ctx)) == 0L || stop())
 invisible(ctx$state == "closed" || stop())
 
@@ -54,8 +58,8 @@ invisible(suppressMessages(close(n$listener[[1]])) == 0L || stop())
 invisible(suppressMessages(close(n1$dialer[[1]])) == 0L || stop())
 invisible(suppressMessages(n$socket_close()) == 0L || stop())
 invisible(suppressMessages(n1$socket_close()) == 0L || stop())
-invisible(n$socket$state == "closed" || stop())
-invisible(n1$socket$state == "closed" || stop())
+invisible(n$socket[["state"]] == "closed" || stop())
+invisible(n1$socket[state] == "closed" || stop())
 
 invisible(is.character(nng_version()) || stop())
 invisible(is.character(nng_error(0L)) || stop())