This creates a dataset for consuming PubSub messages.
pubsub_dataset(subscriptions, server = NULL, eof = FALSE, timeout = 1000)
subscriptions | A |
---|---|
server | The pubsub server. |
eof | If True, the pubsub reader will stop on EOF. |
timeout | The timeout value for the PubSub to wait (in millisecond). |