def flush(self):
        # mark checkpoint (complete message)
        logger.debug("debug %s flushing..." % self.__name)
        self.put(None)
        # wait until it is processed
        self.join()
        logger.debug("debug %s flush done" % self.__name)
dataset/ETHPy150Open uwdata/termite-visualizations/web2py/gluon/debug.py/Pipe.flush/original