1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
### Iterative pollers
# SHELL> Rscript iter_try.r
library(pbdZMQ, quietly = TRUE)
### Initial.
context <- zmq.ctx.new()
receiver <- zmq.socket(context, .pbd_env$ZMQ.ST$PULL)
zmq.connect(receiver, "tcp://localhost:5557")
### Process messages from the socket.
for(i in 1:5){
cat("Press Ctrl+C or Esc to stop iter_script ... ", i, "\n", sep = "")
aa <- tryCatch(zmq.poll2.interrupt(c(receiver), c(.pbd_env$ZMQ.PO$POLLIN)),
interrupt = function(c){ c$ret$pollret })
print(aa)
}
### Finish.
zmq.close(receiver)
zmq.ctx.destroy(context)
|
