Package pubsubio provides access to PubSub on Dataflow streaming. Experimental.
Read reads an unbounded number of PubSubMessages from the given pubsub topic. It produces an unbounded PCollecton<*PubSubMessage>, if WithAttributes is set, or an unbounded PCollection<byte>.
Write writes PubSubMessages or bytes to the given pubsub topic.
ReadOptions represents options for reading from PubSub.
|v1||Package v1 is a generated protocol buffer package.|