dddp/main.py
def run(self):
        """Run DDP greenlets."""
        self.logger.debug('PostgresGreenlet run')
        self.start()
        self._stop_event.wait()
        # wait for all threads to stop.
        gevent.joinall(self.threads + [DDPLauncher.pgworker])
        self.threads = []
def run(self):
        """Run DDP greenlets."""
        self.logger.debug('PostgresGreenlet run')
        self.start()
        self._stop_event.wait()
        # wait for all threads to stop.
        gevent.joinall(self.threads + [DDPLauncher.pgworker])
        self.threads = []
def run ( self ) : self . logger . debug ( 'PostgresGreenlet run' ) self . start ( ) self . _stop_event . wait ( ) # wait for all threads to stop. gevent . joinall ( self . threads + [ DDPLauncher . pgworker ] ) self . threads = [ ]
Run DDP greenlets.
Run DDP greenlets .