Skip to content

Commit 5e83033

Browse files
committed
update for request_promise -> request2
1 parent a61c070 commit 5e83033

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

DESCRIPTION

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ Encoding: UTF-8
2323
Depends:
2424
R (>= 3.6)
2525
Imports:
26-
nanonext (>= 0.13.6.9001)
26+
nanonext (>= 0.13.6.9002)
2727
Enhances:
2828
parallel,
2929
promises

NAMESPACE

+1-1
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ importFrom(nanonext,reap)
6565
importFrom(nanonext,recv)
6666
importFrom(nanonext,recv_aio_signal)
6767
importFrom(nanonext,request)
68-
importFrom(nanonext,request_promise)
68+
importFrom(nanonext,request2)
6969
importFrom(nanonext,request_signal)
7070
importFrom(nanonext,send)
7171
importFrom(nanonext,socket)

R/mirai-package.R

+1-1
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@
4444
#'
4545
#' @importFrom nanonext call_aio call_aio_ .context cv cv_value dial
4646
#' is_error_value listen lock mclock msleep next_config opt opt<- parse_url
47-
#' pipe_notify random reap recv recv_aio_signal request request_promise
47+
#' pipe_notify random reap recv recv_aio_signal request request2
4848
#' request_signal send socket stat stop_aio strcat tls_config unresolved
4949
#' until wait write_cert
5050
#' @importFrom parallel nextRNGStream

R/mirai.R

+2-2
Original file line numberDiff line numberDiff line change
@@ -145,10 +145,10 @@ mirai <- function(.expr, ..., .args = list(), .timeout = NULL, .compute = "defau
145145
envir <- ..[[.compute]]
146146
if (is.null(envir)) {
147147
sock <- ephemeral_daemon(local_url())
148-
aio <- request_promise(.context(sock), data = data, cv = NULL, send_mode = 1L, recv_mode = 1L, timeout = .timeout)
148+
aio <- request2(.context(sock), data = data, send_mode = 1L, recv_mode = 1L, timeout = .timeout)
149149
`attr<-`(.subset2(aio, "aio"), "sock", sock)
150150
} else {
151-
aio <- request_promise(.context(envir[["sock"]]), data = data, cv = envir[["cv"]], send_mode = 3L, recv_mode = 1L, timeout = .timeout)
151+
aio <- request2(.context(envir[["sock"]]), data = data, cv = envir[["cv"]], send_mode = 3L, recv_mode = 1L, timeout = .timeout)
152152
}
153153

154154
`class<-`(aio, c("mirai", "recvAio"))

0 commit comments

Comments
 (0)