Dispatch one message to all outgoing edges.
(self, message:dict[str,object])
| 249 | return input |
| 250 | @masf_hook(Hook.MESSAGE_DISPATCH_OUT) |
| 251 | def _message_dispatch_out(self, message:dict[str,object]): |
| 252 | """Dispatch one message to all outgoing edges.""" |
| 253 | for out_edge in self.out_edges: |
| 254 | out_edge.send_message(message) |
| 255 | self._gate = Gate.OPEN |
| 256 | |
| 257 | def _close_out_edges(self): |
| 258 | """Close all outgoing edges.""" |