Lines Matching refs:remaining

191             remaining = static_remaining_time_delta(end_time)
192 …         logging.debug("Waiting for event iteration (%fs remaining)" % (remaining.total_seconds()))
194                 current_event = self.event_queue.get(timeout=remaining.total_seconds())
206     remaining = end_time - datetime.now()
207     if remaining < timedelta(milliseconds=0):
208         remaining = timedelta(milliseconds=0)
209     return remaining
220         remaining = static_remaining_time_delta(end_time)
221         logging.debug("Waiting for event (%fs remaining)" % (remaining.total_seconds()))
223             current_event = istream.get_event_queue().get(timeout=remaining.total_seconds())
244         remaining = static_remaining_time_delta(end_time)
245         logging.debug("Waiting for event (%fs remaining)" % (remaining.total_seconds()))
247             current_event = istream.get_event_queue().get(timeout=remaining.total_seconds())
274         remaining = static_remaining_time_delta(end_time)
275         logging.debug("Waiting for event (%fs remaining)" % (remaining.total_seconds()))
277             current_event = istream.get_event_queue().get(timeout=remaining.total_seconds())