'Forward the connection lost event, flushing remaining data from the
decompressor if any.'

def connectionLost(self, reason):

    try:
        rawData = self._zlibDecompress.flush()
    except zlib.error:
        raise ResponseFailed([reason, Failure()], self._response)
    if rawData:
        self.original.dataReceived(rawData)
    self.original.connectionLost(reason)
