class_docstr: Utility to watch the value of the cache entries with kind 'dataset-hub-cache'.
class_docstr_tok: ["Utility","to","watch","the","value","of","the","cache","entries","with","kind","'dataset-hub-cache","'","."]
code: def __init__(
      self,
      client: AsyncIOMotorClient,
      db_name: str,
      collection_name: str,
  ) -> None:
      self._client = client
      self._collection = self._client[db_name][collection_name]
      self._publisher = HubCachePublisher(_watchers={})
  
imports: import asyncio
  import contextlib
  from collections.abc import Mapping, Sequence
  from dataclasses import dataclass
  from http import HTTPStatus
  from typing import Any, Optional
  from uuid import uuid4
  from motor.motor_asyncio import AsyncIOMotorClient
  from pymongo.errors import PyMongoError
  from sse_api.constants import HUB_CACHE_KIND
label_desc: Use image node_id 1 to create a new HubCacheWatcher object  with example: obj = HubCacheWatcher(client, db_name, collection_name)