move back to public interface

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: mirai
 Type: Package
 Title: Minimalist Async Evaluation Framework for R
-Version: 0.10.0.9008
+Version: 0.10.0.9009
 Description: Lightweight parallel code execution and distributed computing.
     Designed for simplicity, a 'mirai' evaluates an R expression asynchronously,
     on local or network resources, resolving automatically upon completion.
@@ -23,5 +23,5 @@ Encoding: UTF-8
 Depends: 
     R (>= 3.5)
 Imports: 
-    nanonext (>= 0.10.0.9008)
+    nanonext (>= 0.10.0.9009)
 RoxygenNote: 7.2.3

NEWS.md

@@ -1,9 +1,9 @@
-# mirai 0.10.0.9008 (development)
+# mirai 0.10.0.9009 (development)
 
 * `daemon()` argument 'exitlinger' retired as daemons now synchronise with the host/dispatcher and exit as soon as possible.
 * Optimises scheduling at dispatcher: tasks are no longer assigned to a daemon if it is exiting due to specified time/task-outs.
 * Deprecated use of alias `server()` for `daemon()` is retired.
-* Requires nanonext >= [0.10.0.9008].
+* Requires nanonext >= [0.10.0.9009].
 
 # mirai 0.10.0
 

R/mirai-package.R

@@ -100,5 +100,5 @@ NULL
   ),
   hash = TRUE
 )
-.seven <- as.raw(7L)
+.next_format_identifier <- as.raw(7L)
 .timelimit <- 5000L

R/mirai.R

@@ -120,7 +120,7 @@ daemon <- function(url, asyncdial = FALSE, maxtasks = Inf, idletime = Inf,
     count <- count + 1L
 
     (count >= maxtasks || count > timerstart && mclock() - start >= walltime) && {
-      send(ctx, data = data, mode = 0L)
+      send(ctx, data = data, mode = 3L)
       data <- recv_aio_signal(sock, cv = cv, mode = 8L)
       wait(cv)
       break
@@ -357,9 +357,9 @@ dispatcher <- function(host, url = NULL, n = NULL, asyncdial = FALSE,
           if (is.object(req)) req <- serialize(req, NULL)
           send(queue[[i]][["ctx"]], data = req, mode = 2L)
           q <- queue[[i]][["daemon"]]
-          if (req[1L] == .seven) {
+          if (req[1L] == .next_format_identifier) {
             ctx <- .context(servers[[q]])
-            send_aio(ctx, data = .seven, mode = 2L)
+            send_aio(ctx, data = .next_format_identifier, mode = 2L)
             reap(ctx)
           } else {
             serverfree[q] <- TRUE