code: def dispatch_result(self, raw_msg):
      try:
          idents, msg = self.session.feed_identities(
              raw_msg, copy=False
          )
          msg = self.session.deserialize(msg, content=False, copy=False)
          outgoing_id = idents[0]
  
      except Exception:
          self.log.error(
              f"broadcast::Invalid broadcast msg: {raw_msg}",
              exc_info=True,
          )
          return
      original_msg_id = msg["metadata"]["original_msg_id"]
      is_coalescing = msg["metadata"]["is_coalescing"]
      if is_coalescing:
          self.coalescing_reply(
              raw_msg, msg, original_msg_id, outgoing_id, idents[1:]
          )
      else:
          self.client_stream.send_multipart(raw_msg[1:], copy=False)
  
file_path: ipyparallel/ipyparallel/controller/broadcast_scheduler.py
imports: import logging
  import zmq
  from traitlets import Bool, Bytes, Integer, List, Unicode
  from ipyparallel import util
  from ipyparallel.controller.scheduler import Scheduler, ZMQStream, get_common_scheduler_streams
label_desc: Use image node_id 6 for calling the BroadcastScheduler obj's underlying member method code with example usage: obj.dispatch_result(raw_msg) without return types