def wait_until_updates_sent(self, multiple_gearman_jobs, poll_timeout=None):
    connection_set = set([current_job.connection for current_job in multiple_gearman_jobs])

    def continue_while_updates_pending(any_activity):
        return compat.any((current_connection.writable() for current_connection in connection_set))
    self.poll_connections_until_stopped(connection_set, continue_while_updates_pending, timeout=poll_timeout)
def wait_until_updates_sent(self, multiple_gearman_jobs, poll_timeout=None):
    connection_set = set([current_job.connection for current_job in multiple_gearman_jobs])

    def continue_while_updates_pending(any_activity):
        return compat.any((current_connection.writable() for current_connection in connection_set))
    self.poll_connections_until_stopped(connection_set, continue_while_updates_pending, timeout=poll_timeout)