Lines Matching refs:current_event

194                 current_event = self.event_queue.get(timeout=remaining.total_seconds())
195                 if match_fn(current_event):
196                     event_list.append(current_event)
223             current_event = istream.get_event_queue().get(timeout=remaining.total_seconds())
224             logging.debug("current_event: %s", current_event)
225             if match_fn(current_event):
226                 event_list.append(current_event)
247             current_event = istream.get_event_queue().get(timeout=remaining.total_seconds())
249                 if match_fn(current_event):
277             current_event = istream.get_event_queue().get(timeout=remaining.total_seconds())
278             if match_fn(current_event):
279                 event = current_event