From d572f4c56c30fa2039d65ef49957903f0f34ca87 Mon Sep 17 00:00:00 2001 From: Tom Christie Date: Sat, 6 Apr 2019 13:44:35 +0100 Subject: [PATCH] Tweak GatewayServer example --- README.md | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/README.md b/README.md index 63eb03dd..7aad6755 100644 --- a/README.md +++ b/README.md @@ -116,14 +116,7 @@ class GatewayServer: if query: url += '?' + query.decode() - async def body(): - nonlocal receive - - while True: - message = await receive() - yield message.get('body', b'') - if not message.get('more_body', False): - break + body = self.stream_body(receive) response = await self.http.request( method, url, headers=headers, body=body, stream=True @@ -142,6 +135,12 @@ class GatewayServer: }) await send({'type': 'http.response.body'}) + async def stream_body(self, receive): + while True: + message = await receive() + yield message.get('body', b'') + if not message.get('more_body', False): + break app = GatewayServer('http://example.org') ```