Signals a 'conditionVariable' whenever pipes (individual connections) are added or removed at a socket.
pipe_notify(socket, cv, cv2 = NULL, add = FALSE, remove = FALSE, flag = FALSE)a Socket.
a 'conditionVariable' to signal.
[default NULL] optionally, if specified, a second 'conditionVariable' to signal. Note that this cv is signalled sequentially after the first condition variable.
[default FALSE] logical value whether to signal when a pipe is added.
[default FALSE] logical value whether to signal when a pipe is removed.
[default FALSE] logical value whether to also set a flag in the
'conditionVariable'. This can help distinguish between different types of
signal, and causes any subsequent wait to return FALSE
instead of TRUE. If a signal from the tools package, e.g.
tools::SIGINT, or an equivalent integer value is supplied, this
sets a flag and additionally raises this signal upon the flag being set.
Invisibly, zero on success (will otherwise error).
For add: this event occurs after the pipe is fully added to the socket. Prior to this time, it is not possible to communicate over the pipe with the socket.
For remove: this event occurs after the pipe has been removed from the socket. The underlying transport may be closed at this point, and it is not possible to communicate using this pipe.
s <- socket(listen = "inproc://nanopipe")
cv <- cv()
cv2 <- cv()
pipe_notify(s, cv, cv2, add = TRUE, remove = TRUE, flag = TRUE)
cv_value(cv)
#> [1] 0
cv_value(cv2)
#> [1] 0
s1 <- socket(dial = "inproc://nanopipe")
cv_value(cv)
#> [1] 1
cv_value(cv2)
#> [1] 1
close(s1)
cv_value(cv)
#> [1] 2
cv_value(cv2)
#> [1] 2
(wait(cv))
#> [1] FALSE
(wait(cv2))
#> [1] FALSE
close(s)