diff --git a/ahserver/proxyProcessor.py b/ahserver/proxyProcessor.py index e916f5c..daf09be 100644 --- a/ahserver/proxyProcessor.py +++ b/ahserver/proxyProcessor.py @@ -29,12 +29,14 @@ class ProxyProcessor(BaseProcessor): allow_redirects=False, data=await request.read()) as res: headers = res.headers.copy() - body = await res.read() + # body = await res.read() self.retResponse = web.Response( headers = headers, - status = res.status, - body = body + status = res.status + # , body=body ) + async for chunk in res.content.iter_chunked(chunk_size): + await self.retResponse.write(chunk) print('proxy: datahandle() finish', self.retResponse)