def METHOD_NAME(self):
    status = MPI.Status()
    while True:
        if self.comm.comm.Iprobe(MPI.ANY_SOURCE, YT_TAG_MESSAGE, status=status):
            msg = self.comm.comm.recv(source=status.source, tag=YT_TAG_MESSAGE)
            if msg["op"] == "end":
                mylog.debug("Shutting down IO.")
                break
            self._send_data(msg, status.source)
            status = MPI.Status()
        else:
            time.sleep(1e-2)