fixes until()

Author: shikokuchuo

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: nanonext
 Type: Package
 Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
-Version: 0.8.1.9026
+Version: 0.8.1.9027
 Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is 
     a socket library providing high-performance scalability protocols, a
     cross-platform standard for messaging and communications. Serves as a

NEWS.md

@@ -1,4 +1,4 @@
-# nanonext 0.8.1.9026
+# nanonext 0.8.1.9027
 
 #### New Features
 
@@ -8,7 +8,8 @@
 
 * `context()` gains the argument 'verify' with a default of TRUE. This adds additional protection to notably the `request()` and `request_signal()` functions when using timeouts, as these require a connection to be present.
 * Sending and hashing of language objects and symbols is now possible after fixes to serialisation.
-* Removes `msg_pipe()` and `'weakref<-'()` introduced in the last release to maintain simplicity of user interface.
+* `until()` now works as intended.
+* Removes recently-introduced `msg_pipe()` and `'weakref<-'()` to maintain simplicity of user interface.
 * Internal performance enhancements.
 
 # nanonext 0.8.1

R/context.R

@@ -161,8 +161,8 @@ reply <- function(context,
 #' @param data an object (if send_mode = 'raw', a vector).
 #' @param timeout [default NULL] integer value in milliseconds or NULL, which
 #'     applies a socket-specific default, usually the same as no timeout. The
-#'     context must be verified - created with \code{context(verify = TRUE)}, or
-#'     else this value will be ignored.
+#'     context must have created with \code{context(verify = TRUE)}, or else
+#'     this value will be ignored.
 #'
 #' @return A 'recvAio' (object of class 'recvAio') (invisibly).
 #'

man/request.Rd

@@ -1411,8 +1411,8 @@ SEXP rnng_cv_until(SEXP cvar, SEXP msec) {
   nng_mtx_lock(mtx);
   while (ncv->condition == 0) {
     if (nng_cv_until(cv, time) == NNG_ETIMEDOUT) break;
-    ncv->condition--;
   }
+  if (ncv->condition > 0) ncv->condition--;
   nng_mtx_unlock(mtx);
 
   return ncv->flag ? Rf_ScalarLogical(0) : Rf_ScalarLogical(1);