package description language

Author: shikokuchuo

DESCRIPTION

@@ -8,7 +8,8 @@ Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is
     concurrency framework for building distributed applications, utilising 'aio'
     objects which resolve automatically upon completion of asynchronous
     operations. Provides synchronisation primitives which allow R to wait upon
-    socket events or message receives signalled by other underlying threads.
+    socket events or message receives being signalled by other underlying
+    threads.
 Authors@R: 
     c(person(given = "Charlie",
              family = "Gao",

R/nanonext-package.R

@@ -24,8 +24,8 @@
 #'     concurrency framework for building distributed applications, utilising
 #'     'aio' objects which resolve automatically upon completion of asynchronous
 #'     operations. Provides synchronisation primitives which allow R to wait
-#'     upon socket events or message receives signalled by other underlying
-#'     threads.
+#'     upon socket events or message receives being signalled by other
+#'     underlying threads.
 #'
 #' @section Usage notes:
 #'

README.Rmd

@@ -22,7 +22,7 @@ knitr::opts_chunk$set(
 [![codecov](https://codecov.io/gh/shikokuchuo/nanonext/branch/main/graph/badge.svg)](https://app.codecov.io/gh/shikokuchuo/nanonext)
 <!-- badges: end -->
 
-R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is a socket library implementing high-performance scalability protocols, a cross-platform standard for messaging and communications. Serves as a concurrency framework for building distributed applications, utilising 'aio' objects which resolve automatically upon completion of asynchronous operations. Provides synchronisation primitives which allow R to wait upon socket events or message receives signalled by other underlying threads.
+R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is a socket library implementing high-performance scalability protocols, a cross-platform standard for messaging and communications. Serves as a concurrency framework for building distributed applications, utilising 'aio' objects which resolve automatically upon completion of asynchronous operations. Provides synchronisation primitives which allow R to wait upon socket events or message receives being signalled by other underlying threads.
 
 Designed for performance and reliability, the NNG library is written in C and {nanonext} is a lightweight zero-dependency wrapper. Provides the interface for code and processes to communicate with each other - receive data generated in Python, perform analysis in R, and send results to a C++ program – all on the same computer or on networks spanning the globe.
 

README.md

@@ -19,8 +19,8 @@ cross-platform standard for messaging and communications. Serves as a
 concurrency framework for building distributed applications, utilising
 ‘aio’ objects which resolve automatically upon completion of
 asynchronous operations. Provides synchronisation primitives which allow
-R to wait upon socket events or message receives signalled by other
-underlying threads.
+R to wait upon socket events or message receives being signalled by
+other underlying threads.
 
 Designed for performance and reliability, the NNG library is written in
 C and {nanonext} is a lightweight zero-dependency wrapper. Provides the
@@ -369,7 +369,7 @@ aio
 #> < recvAio >
 #>  - $data for message data
 aio$data |> str()
-#>  num [1:100000000] 0.367 -0.967 -1.123 -1.016 -1.009 ...
+#>  num [1:100000000] 0.741 -0.123 0.41 -0.82 -0.109 ...
 ```
 
 As `call_aio()` is blocking and will wait for completion, an alternative
@@ -653,11 +653,11 @@ ncurl("https://httpbin.org/headers")
 #>   [1] 7b 0a 20 20 22 68 65 61 64 65 72 73 22 3a 20 7b 0a 20 20 20 20 22 48 6f 73
 #>  [26] 74 22 3a 20 22 68 74 74 70 62 69 6e 2e 6f 72 67 22 2c 20 0a 20 20 20 20 22
 #>  [51] 58 2d 41 6d 7a 6e 2d 54 72 61 63 65 2d 49 64 22 3a 20 22 52 6f 6f 74 3d 31
-#>  [76] 2d 36 34 31 64 39 38 32 34 2d 34 66 37 35 30 37 37 38 32 63 39 34 62 35 37
-#> [101] 33 36 33 37 35 64 37 31 35 22 0a 20 20 7d 0a 7d 0a
+#>  [76] 2d 36 34 31 64 39 62 38 39 2d 33 32 39 38 36 33 35 36 35 31 37 35 61 35 63
+#> [101] 64 30 39 36 64 31 34 32 38 22 0a 20 20 7d 0a 7d 0a
 #> 
 #> $data
-#> [1] "{\n  \"headers\": {\n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-641d9824-4f7507782c94b5736375d715\"\n  }\n}\n"
+#> [1] "{\n  \"headers\": {\n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-641d9b89-329863565175a5cd096d1428\"\n  }\n}\n"
 ```
 
 For advanced use, supports additional HTTP methods such as POST or PUT.
@@ -678,13 +678,13 @@ res
 
 call_aio(res)$headers
 #> $Date
-#> [1] "Fri, 24 Mar 2023 12:31:33 GMT"
+#> [1] "Fri, 24 Mar 2023 12:46:02 GMT"
 #> 
 #> $Server
 #> [1] "gunicorn/19.9.0"
 
 res$data
-#> [1] "{\n  \"args\": {}, \n  \"data\": \"{\\\"key\\\": \\\"value\\\"}\", \n  \"files\": {}, \n  \"form\": {}, \n  \"headers\": {\n    \"Authorization\": \"Bearer APIKEY\", \n    \"Content-Length\": \"16\", \n    \"Content-Type\": \"application/json\", \n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-641d9825-18dd512a143d4966197d9566\"\n  }, \n  \"json\": {\n    \"key\": \"value\"\n  }, \n  \"origin\": \"131.111.5.14\", \n  \"url\": \"http://httpbin.org/post\"\n}\n"
+#> [1] "{\n  \"args\": {}, \n  \"data\": \"{\\\"key\\\": \\\"value\\\"}\", \n  \"files\": {}, \n  \"form\": {}, \n  \"headers\": {\n    \"Authorization\": \"Bearer APIKEY\", \n    \"Content-Length\": \"16\", \n    \"Content-Type\": \"application/json\", \n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-641d9b8a-2943c4756324ceec68482488\"\n  }, \n  \"json\": {\n    \"key\": \"value\"\n  }, \n  \"origin\": \"131.111.5.14\", \n  \"url\": \"http://httpbin.org/post\"\n}\n"
 ```
 
 In this respect, it may be used as a performant and lightweight method
@@ -710,7 +710,7 @@ transact(sess)
 #> 
 #> $headers
 #> $headers$date
-#> [1] "Fri, 24 Mar 2023 12:31:34 GMT"
+#> [1] "Fri, 24 Mar 2023 12:46:03 GMT"
 #> 
 #> 
 #> $raw
@@ -721,14 +721,14 @@ transact(sess)
 #> [101] 69 6f 6e 2f 6a 73 6f 6e 22 2c 20 0a 20 20 20 20 22 48 6f 73 74 22 3a 20 22
 #> [126] 68 74 74 70 62 69 6e 2e 6f 72 67 22 2c 20 0a 20 20 20 20 22 58 2d 41 6d 7a
 #> [151] 6e 2d 54 72 61 63 65 2d 49 64 22 3a 20 22 52 6f 6f 74 3d 31 2d 36 34 31 64
-#> [176] 39 38 32 36 2d 35 65 62 32 63 32 33 34 37 36 36 62 65 33 38 63 31 62 61 33
-#> [201] 32 31 61 66 22 0a 20 20 7d 2c 20 0a 20 20 22 6f 72 69 67 69 6e 22 3a 20 22
+#> [176] 39 62 38 62 2d 37 64 66 32 33 34 37 66 31 35 30 61 64 38 30 36 33 64 63 62
+#> [201] 31 36 66 30 22 0a 20 20 7d 2c 20 0a 20 20 22 6f 72 69 67 69 6e 22 3a 20 22
 #> [226] 37 39 2e 31 37 33 2e 31 32 39 2e 32 22 2c 20 0a 20 20 22 75 72 6c 22 3a 20
 #> [251] 22 68 74 74 70 73 3a 2f 2f 68 74 74 70 62 69 6e 2e 6f 72 67 2f 67 65 74 22
 #> [276] 0a 7d 0a
 #> 
 #> $data
-#> [1] "{\n  \"args\": {}, \n  \"headers\": {\n    \"Authorization\": \"Bearer APIKEY\", \n    \"Content-Type\": \"application/json\", \n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-641d9826-5eb2c234766be38c1ba321af\"\n  }, \n  \"origin\": \"131.111.5.14\", \n  \"url\": \"https://httpbin.org/get\"\n}\n"
+#> [1] "{\n  \"args\": {}, \n  \"headers\": {\n    \"Authorization\": \"Bearer APIKEY\", \n    \"Content-Type\": \"application/json\", \n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-641d9b8b-7df2347f150ad8063dcb16f0\"\n  }, \n  \"origin\": \"131.111.5.14\", \n  \"url\": \"https://httpbin.org/get\"\n}\n"
 ```
 
 [« Back to ToC](#table-of-contents)