code: def __init__(
      self,
      for_write: bool,
      port: int = 0,
      topic=PublisherTopics.StreamItem,
      block_until_connected=True,
      stream_name: str = None,
      console_debug: bool = False,
  ):
      super(ZmqStream, self).__init__(
          stream_name=stream_name, console_debug=console_debug
      )
  
      self.for_write = for_write
      self._zmq = None
  
      self.topic = topic
      self._open(for_write, port, block_until_connected)
      utils.debug_log("ZmqStream started", verbosity=1)
  
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 1 to create a new ZmqStream object from inherited base classes: Stream with example: obj = ZmqStream(for_write, port, topic, block_until_connected, stream_name, console_debug)