@abstractmethod
    def select(self, timeout=None):
        raise NotImplementedError
Perform the actual selection, until some monitored file objects are
dataset/ETHPy150Open dpkp/kafka-python/kafka/selectors34.py/BaseSelector.select