class_docstr: Hook for accessing Google Pub/Sub.
  
  The Google Cloud project against which actions are applied is determined by
  the project embedded in the Connection referenced by gcp_conn_id.
class_docstr_tok: ["Hook","for","accessing","Google","Pub\/Sub",".","The","Google","Cloud","project","against","which","actions","are","applied","is","determined","by","the","project","embedded","in","the","Connection","referenced","by","gcp_conn_id","."]
docstr: Creates SubscriberClient.
  
  :return: Google Cloud Pub/Sub client object.
docstr_tok: ["Creates","SubscriberClient",".",":","return",":","Google","Cloud","Pub\/Sub","client","object","."]
code: def subscriber_client(self) -> SubscriberClient:
      """
      Creates SubscriberClient.
  
      :return: Google Cloud Pub/Sub client object.
      """
      return SubscriberClient(
          credentials=self.get_credentials(), client_info=CLIENT_INFO
      )
  
imports: from __future__ import annotations
  import warnings
  from base64 import b64decode
  from functools import cached_property
  from typing import TYPE_CHECKING, Any, Sequence
  from uuid import uuid4
  from google.api_core.exceptions import AlreadyExists, GoogleAPICallError
  from google.api_core.gapic_v1.method import DEFAULT, _MethodDefault
  from google.cloud.exceptions import NotFound
  from google.cloud.pubsub_v1 import PublisherClient, SubscriberClient
  from google.pubsub_v1.services.subscriber.async_client import SubscriberAsyncClient
  from googleapiclient.errors import HttpError
  from airflow.exceptions import AirflowProviderDeprecationWarning
  from airflow.providers.google.common.consts import CLIENT_INFO
  from airflow.providers.google.common.hooks.base_google import PROVIDE_PROJECT_ID, GoogleBaseAsyncHook, GoogleBaseHook
  from airflow.version import version
label_desc: Use image node_id 3 for calling the PubSubHook obj's underlying member method code with example usage: obj.subscriber_client() and returns: SubscriberClient