'We\'re never going to send any more data (normally because either
we or the remote has closed the connection)'

def stopProducing(self):

    logger.info('[%s]    Stop    producing', self.id())
    self.on_connection_closed()
