def stopProducing(self):
self._finish(True)<EOL>if self._deferred and self._sent < self.length:<EOL><INDENT>self._deferred.errback(Exception("<STR_LIT>" % (self._sent, self.length)))<EOL><DEDENT>
Stop producing