'Utility function that kills all coroutines currently running.'

def kill_coros(self):

    for coro in list(self.run_pool.coroutines_running):
        try:
            coro.kill(GreenletExit)
        except GreenletExit:
            pass
