Add id attribute for mirai (#408)

* Add id attribute for mirai

* Supply R_MissingArg to request(cv =)

Author: shikokuchuo

DESCRIPTION

@@ -1,7 +1,7 @@
 Type: Package
 Package: mirai
 Title: Minimalist Async Evaluation Framework for R
-Version: 2.4.1.9001
+Version: 2.4.1.9002
 Authors@R: c(
     person("Charlie", "Gao", , "[email protected]", role = c("aut", "cre"),
            comment = c(ORCID = "0000-0002-0750-061X")),
@@ -27,7 +27,7 @@ BugReports: https://github.com/r-lib/mirai/issues
 Depends: 
     R (>= 3.6)
 Imports: 
-    nanonext (>= 1.6.2.9001)
+    nanonext (>= 1.6.2.9002)
 Suggests: 
     cli,
     litedown

NEWS.md

@@ -11,6 +11,7 @@
 
 * New `with_daemons()` and `local_daemons()` helper functions for using a particular compute profile.
   This works with daemons that are already set up unlike the existing `with.miraiDaemons()` method, which creates a new scope and tears it down when finished (#360).
+* Each mirai now has an attribute `id`, which is a monotonically increasing integer identifier in each session.
 
 #### Updates
 
@@ -31,7 +32,7 @@
   + Preserves the original condition classes and may be re-thrown as the original condition (thanks @sebffischer, #400).
   + The print method includes the customary additional line break (thanks @sebffischer, #399).
 * A `mirai()` evaluated on an ephemeral daemon returns invisibly, consistent with other cases (#351).
-* Requires nanonext >= [1.6.2.9001].
+* Requires nanonext >= [1.6.2.9002].
 
 # mirai 2.4.1
 

R/mirai.R

@@ -9,7 +9,9 @@
 #' This function will return a 'mirai' object immediately.
 #'
 #' The value of a mirai may be accessed at any time at `$data`, and if yet
-#' to resolve, an 'unresolved' logical NA will be returned instead.
+#' to resolve, an 'unresolved' logical NA will be returned instead. Each mirai
+#' has an attribute `id`, which is a monotonically increasing integer identifier
+#' in each session.
 #'
 #' [unresolved()] may be used on a mirai, returning TRUE if a 'mirai' has yet to
 #' resolve and FALSE otherwise. This is suitable for use in control flow
@@ -419,7 +421,7 @@ stop_mirai <- function(x) {
   aio <- .subset2(x, "aio")
   !is.integer(aio) &&
     attr(aio, "id") > 0 &&
-    query_dispatcher(attr(aio, "context"), c(0L, attr(aio, "id")))
+    query_dispatcher(attr(aio, "context"), c(0L, attr(x, "id")))
 }
 
 #' Query if a mirai is Unresolved
@@ -597,7 +599,7 @@ ephemeral_daemon <- function(data, timeout) {
     send_mode = 1L,
     recv_mode = 1L,
     timeout = timeout,
-    cv = NA
+    cv = substitute()
   )
   `attr<-`(.subset2(aio, "aio"), "sock", sock)
   invisible(aio)

man/mirai.Rd

@@ -70,6 +70,7 @@ connection && {
     q / m
   }, m = 2L, .args = environment(), .timeout = 2000L)
   test_identical(call_mirai(m), m)
+  test_type("integer", attr(m, "id"))
   if (!is_error_value(m$data)) test_equal(m$data, 3L)
   Sys.sleep(1L)
   `lang obj` <- quote(m + n + 2L)