code: def __init__(
      self,
      clisrv: ZmqWrapper.ClientServer,
      for_write: bool,
      port: int = 0,
      topic=PublisherTopics.ServerMgmt,
      block_until_connected=True,
      stream_name: str = None,
      console_debug: bool = False,
  ):
      super(ZmqMgmtStream, self).__init__(
          for_write=for_write,
          port=port,
          topic=topic,
          block_until_connected=block_until_connected,
          stream_name=stream_name,
          console_debug=console_debug,
      )
  
      self._clisrv = clisrv
      self._stream_reqs: Dict[str, StreamCreateRequest] = {}
  
file_path: tensorwatch/tensorwatch/zmq_mgmt_stream.py
imports: from typing import Any
  from .zmq_stream import ZmqStream
  from .lv_types import PublisherTopics, ServerMgmtMsg, StreamCreateRequest
  from .zmq_wrapper import ZmqWrapper
  from .lv_types import CliSrvReqTypes, ClientServerRequest
  from .None import utils
label_desc: Use image node_id 1 to create a new ZmqMgmtStream object from inherited base classes: ZmqStream with example: obj = ZmqMgmtStream(clisrv, for_write, port, topic, block_until_connected, stream_name, console_debug)