def threadbound(self, _cls=_StackBound):
        return _cls(self, self.push_thread, self.pop_thread)
Send FetchRequests asynchronously for all assigned partitions.
dataset/ETHPy150Open getlogbook/logbook/logbook/_fallback.py/StackedObject.threadbound--crossover with--dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/fetcher.py/Fetcher.init_fetches