skip queue processing

shikokuchuo · Jan 9, 2025 · 50b1be9 · 50b1be9
1 parent 0d17f22
commit 50b1be9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/R/dispatcher.R b/R/dispatcher.R
@@ -216,6 +216,7 @@ dispatcher <- function(host, url = NULL, n = NULL, ..., tls = NULL, pass = NULL,
           if (length(outq[[id]][["dmnid"]]))
             events <- c(events, outq[[id]][["dmnid"]])
           outq[[id]] <- NULL
+          next
         } else {
           send(outq[[id]][["ctx"]], value, mode = 2L, block = TRUE)
           outq[[id]][["msgid"]] <- 0L