code: def write(self, val: Any, from_stream: "Stream" = None, topic=None):
      stream_item = self.to_stream_item(val)
  
      if self.for_write:
          topic = topic or self.topic
          utils.debug_log("Sent subscription item", verbosity=5)
          self._zmq.send_obj(stream_item, topic)
      # else if this was opened for read then we have subscription and
      # we shouldn't be calling send_obj
      super(ZmqStream, self).write(stream_item)
  
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 5 for calling the ZmqStream obj's underlying member method code with example usage: obj.write(val, from_stream, topic) without return types