def test_pullProducer(self):
        class PullProducer(object):
            implements(IPullProducer)

            def __init__(self, toProduce):
                self.toProduce = toProduce

            def start(self, consumer):
                self.consumer = consumer
                self.consumer.registerProducer(self, False)

            def resumeProducing(self):
                self.consumer.write(self.toProduce.pop(0))
                if not self.toProduce:
                    self.consumer.unregisterProducer()
        return self._producertest(PullProducer)
Raise an exception if the input fails to parse correctly.
dataset/ETHPy150Open kuri65536/python-for-android/python-modules/twisted/twisted/test/test_loopback.py/LoopbackAsyncTestCase.test_pullProducer--crossover with--dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/search/expression_parser.py/ExpressionParserWithErrors.emitErrorMessage