devOpifex
How to handle non-blocking async operations with coro in ambiorix?
Problem : I'm trying to make a long running task non blocking using async from coro in ambiorix but still getting blocked / delayed even though the function is asynchronously declared.
Goal : To let the server handle other requests in the meantime.
Reproducible Example :
app.R
box::use(
. / router[router],
)
box::use(
ambiorix[Ambiorix]
)
app <- Ambiorix$new()
app$use(router)
app$start(port = 2050, host = "127.0.0.1")
router.R
box::use(
ambiorix[Router]
)
box::use(
. / controller[servePingInfo, serveLongRunningTask]
)
#' @export
router <- Router$new("/")
router$get("/ping", servePingInfo)
router$get("/long-task", serveLongRunningTask)
controller.R
box::use(
ambiorix[Router],
coro[async]
)
#' @export
servePingInfo <- async(function(req, res) {
status <- "sucess"
res$json(status)
})
#' @export
serveLongRunningTask <- async(function(req, res) {
Sys.sleep(10)
status <- "YOur wait is over"
res$json(status)
})
Current Behavior : When hitting the /long-task endpoint, the server blocks for 10 seconds due to Sys.sleep(10) before responding. During this time, no other requests can be handled.
Note : It would be helpful if asynchronous approach can be done using coro libraries as it looks more similar to JavaScript.
Main thing to notice is that I'm not using await(). I cannot use await here like this router$get("/ping", await(servePingInfo)). This throws an error
I have though a little for async in ambiorix too. I think it's worth exploring similar approach as ExtendedTask + furure/mirai. Correct me if i'm wrong @JohnCoene, I think the current approach is using belgic.
The way we have async is just using future, see here, we can consider support for coro, i just need to understand the library a bit more to know what needs adapting in Ambiorix.
Belgic is a vertical load balancer for ambiorix, similar to shiny server.
hi @spirae-nevin, can you provide a minimal reprex showing how to use {coro} for non-blocking async operations? (without ambiorix, just in a plain R session). would be happy to help!
The coro library has examples : https://coro.r-lib.org/reference/async.html
