def __init__(self, extractor, locator, classifier):

        self.classifier = classifier
        self.extractor = extractor
        self.locator = locator
        self.training_data = []
When the streaming producer is paused, the underlying producer stops
dataset/ETHPy150Open ChrisBeaumont/brut/bubbly/model.py/Model.__init__--crossover with--dataset/ETHPy150Open nlloyd/SubliminalCollaborator/libs/twisted/protocols/test/test_tls.py/NonStreamingProducerTests.test_pause