code: def publish(self, msg):
          '''
          Send message to all connected sockets
          '''
          if not self.streams:
              return
  
          pack = salt.transport.frame.frame_msg_ipc(msg, raw_body=True)
  
          for stream in self.streams:
              self.io_loop.spawn_callback(self._write, stream, packf publish(self, msg):
          '''
          Send message to all connected sockets
          '''
          if not self.streams:
              return
  
          pack = salt.transport.frame.frame_msg_ipc(msg, raw_body=True)
  
          for stream in self.streams:
              self.io_loop.spawn_callback(self._write, stream, pack)
docs: Send message to all connected sockets