def _create_results_collection(self):
        return BulkInsertBuffer(Result)
stream has been closed (won't be in controller's list anymore)
dataset/ETHPy150Open openelections/openelections-core/openelex/us/wa/transform/__init__.py/CreateResultsTransform._create_results_collection--crossover with--dataset/ETHPy150Open meejah/txtorcon/test/test_stream.py/Listener.stream_closed