docs: def send(self, msg, timeout=None, tries=None):
          '''
          Send a message to an IPC socket
  
          If the socket is not currently connected, a connection will be established.
  
          :param dict msg: The message to be sent
          :param int timeout: Timeout when sending message (Currently unimplemented)
          '''
          if not self.connected():
              yield self.connect()
          pack = salt.transport.frame.frame_msg_ipc(msg, raw_body=True)
          yield self.stream.write(pack)