Skip to content

Commit

Permalink
use latest nanonext interface
Browse files Browse the repository at this point in the history
  • Loading branch information
shikokuchuo committed Dec 2, 2024
1 parent d9ed3a9 commit 4d7b844
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions DESCRIPTION
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
Package: mirai
Type: Package
Title: Minimalist Async Evaluation Framework for R
Version: 1.3.1.9012
Version: 1.3.1.9013
Description: Designed for simplicity, a 'mirai' evaluates an R expression
asynchronously in a parallel process, locally or distributed over the
network, with the result automatically available upon completion. Modern
Expand Down Expand Up @@ -33,7 +33,7 @@ Encoding: UTF-8
Depends:
R (>= 3.6)
Imports:
nanonext (>= 1.3.2.9012)
nanonext (>= 1.3.2.9013)
Enhances:
parallel,
promises
Expand Down
4 changes: 2 additions & 2 deletions NEWS.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# mirai 1.3.1.9012 (development)
# mirai 1.3.1.9013 (development)

#### New Features

Expand All @@ -10,7 +10,7 @@

* Experimental threaded dispatcher `daemons(dispatcher = "thread")` has been retired (as this was based on the old dispatcher architecture and future development will focus on the current design). Specifying 'dispatcher = thread' is defunct, but will point to 'dispatcher = process' for the time being.
* `daemon()` '...' argument had been moved up to prevent partial matching on any of the optional arguments.
* Requires `nanonext` >= [1.3.2.9012].
* Requires `nanonext` >= [1.3.2.9013].

# mirai 1.3.1

Expand Down
2 changes: 1 addition & 1 deletion R/daemon.R
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ daemon <- function(url, ..., dispatcher = FALSE, asyncdial = FALSE, autoexit = T
aio <- recv_aio(sock, mode = 1L, cv = cv)
wait(cv) || break
m <- collect_aio(aio)
cancel <- recv_aio(sock, mode = 8L)
cancel <- recv_aio(sock, mode = 8L, cv = NA)
data <- eval_mirai(m)
stop_aio(cancel)
send(sock, data, mode = 1L, block = TRUE)
Expand Down

0 comments on commit 4d7b844

Please sign in to comment.