def _pollWriteQueue(self):
        self._write_task = self._write_queue.get()
        self._write_task.addCallback(self._writeData)
This method must be implemented by collectors, and is called
dataset/ETHPy150Open nskinkel/oppy/oppy/circuit/circuit.py/Circuit._pollWriteQueue--crossover with--dataset/ETHPy150Open kiip/statsite/statsite/collector.py/Collector.start