Searched refs:filter_fn (Results 1 – 1 of 1) sorted by relevance
41 def __init__(self, stream, filter_fn): argument42 self.filter_fn = filter_fn if filter_fn else lambda x: x46 …self.stream.register_callback(self.__event_callback, lambda packet: self.filter_fn(packet) is not …49 self.event_queue.put(self.filter_fn(event))