Skip to content

Commit

Permalink
more threaded dispatcher tests
Browse files Browse the repository at this point in the history
  • Loading branch information
shikokuchuo committed Oct 1, 2024
1 parent 45cbf36 commit 1bcd7a6
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion tests/tests.R
Original file line number Diff line number Diff line change
Expand Up @@ -523,14 +523,16 @@ test_error(.dispatcher(host = "inproc://hostdisp", url = "inproc://disp/1", tls
test_type("externalptr", disp <- .dispatcher(host = "inproc://hostdisp", url = "inproc://disp/1", tls = NULL))
test_zero(.online(disp))
test_null(.online("a"))
test_class("nano", s <- socket(protocol = "rep"))
test_class("nanoSocket", s <- socket(protocol = "rep"))
test_zero(pipe_notify(s, cv, add = TRUE))
test_zero(dial(s, url = "inproc://disp/1"))
test_true(wait(cv))
test_zero(send(disp, NULL, block = 500L))
test_null(recv(s, block = 500L))
test_zero(send(s, TRUE, block = 500L))
test_true(recv(disp, block = 500L))
test_zero(send(disp, NULL, block = 500L))
test_null(recv(s, block = 500L))
test_zero(close(s))
rm(disp)

Expand Down

0 comments on commit 1bcd7a6

Please sign in to comment.