This creates a dataset for consuming PubSub messages.

pubsub_dataset(subscriptions, server = NULL, eof = FALSE,
  timeout = 1000)

Arguments

subscriptions

A tf.string tensor containing one or more subscriptions.

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).