class_docstr: StreamIODataset
docstr: Creates an `StreamIODataset` from a pubsub endpoint.
  
  Args:
    subscription: A string, the subscription of the pubsub messages.
    endpoint: A string, the address of pubsub endpoint.
    timeout: An integer, the timeout of the pubsub pull.
    name: A name prefix for the IODataset (optional).
  
  Returns:
    A `IODataset`.
docstr_tok: ["Creates","an","`","StreamIODataset","`","from","a","pubsub","endpoint",".","Args",":","subscription",":","A","string",",","the","subscription","of","the","pubsub","messages",".","endpoint",":","A","string",",","the","address","of","pubsub","endpoint",".","timeout",":","An","integer",",","the","timeout","of","the","pubsub","pull",".","name",":","A","name","prefix","for","the","IODataset","(","optional",")",".","Returns",":","A","`","IODataset","`","."]
code: def from_pubsub(
      cls, subscription, endpoint=None, timeout=10000, **kwargs
  ):
      """Creates an `StreamIODataset` from a pubsub endpoint.
  
      Args:
        subscription: A string, the subscription of the pubsub messages.
        endpoint: A string, the address of pubsub endpoint.
        timeout: An integer, the timeout of the pubsub pull.
        name: A name prefix for the IODataset (optional).
  
      Returns:
        A `IODataset`.
      """
      with tf.name_scope(kwargs.get("name", "IOFromPubSub")):
          return pubsub_dataset_ops.PubSubStreamIODataset(
              subscription,
              endpoint=endpoint,
              timeout=timeout,
              internal=True,
          )
  
imports: import tensorflow
  from tensorflow_io.python.ops import io_dataset
  from tensorflow_io.python.experimental import libsvm_dataset_ops
  from tensorflow_io.python.experimental import image_dataset_ops
  from tensorflow_io.python.experimental import kinesis_dataset_ops
  from tensorflow_io.python.experimental import pubsub_dataset_ops
  from tensorflow_io.python.experimental import grpc_dataset_ops
  from tensorflow_io.python.experimental import file_dataset_ops
  from tensorflow_io.python.experimental import numpy_dataset_ops
  from tensorflow_io.python.experimental import sql_dataset_ops
  from tensorflow_io.python.experimental import video_dataset_ops
label_desc: Use image node_id 3 for calling the StreamIODataset obj's underlying member method code with example usage: obj.from_pubsub(cls, subscription, endpoint, timeout) and returns: pubsub_dataset_ops