'Stop consuming data.
This is called when a producer has lost its connection, to tell the
consumer to go lose its connection (and break potential circular
references).'

def stopConsuming(self):

    self.unregisterProducer()
    self.loseConnection()
