code: def add_stream_req(self, stream_req: StreamCreateRequest) -> None:
      self._send_create_stream(stream_req)
  
      # save this for later for resend if server restarts
      self._stream_reqs[stream_req.stream_name] = stream_req
  
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 3 for calling the ZmqMgmtStream obj's underlying member method code with example usage: obj.add_stream_req(stream_req) without return types