code: def _on_subscription_item(self, val: Any):
      utils.debug_log("Received subscription item", verbosity=5)
      self.write(val)
  
file_path: tensorwatch/tensorwatch/zmq_stream.py
imports: from typing import Any
  from .zmq_wrapper import ZmqWrapper
  from .stream import Stream
  from .lv_types import DefaultPorts, PublisherTopics
  from .None import utils
label_desc: Use image node_id 4 for calling the ZmqStream obj's underlying member method code with example usage: obj._on_subscription_item(val) without return types