tfio (version 0.4.1)

pubsub_dataset: Creates a PubSubDataset.

Description

This creates a dataset for consuming PubSub messages.

Usage

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