def stats(self, start, end, fields=None):
        start = self.pickler.dumps(start)
        end = self.pickler.dumps(end)
        backend = self.read_backend
        return backend.execute(
            backend.structure(self).stats(start, end, fields), self._stats)
When converted to a streaming producer, the non-streaming producer
dataset/ETHPy150Open lsbardel/python-stdnet/stdnet/apps/columnts/models.py/ColumnTS.stats--crossover with--dataset/ETHPy150Open nlloyd/SubliminalCollaborator/libs/twisted/protocols/test/test_tls.py/NonStreamingProducerTests.test_writeUntilDone