From: Tom Christie <tom@tomchristie.com>
Date: Sat, 6 Apr 2019 12:44:35 +0000 (+0100)
Subject: Tweak GatewayServer example
X-Git-Tag: 0.1.0~18
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=d572f4c56c30fa2039d65ef49957903f0f34ca87;p=thirdparty%2Fhttpx.git

Tweak GatewayServer example
---

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')
 ```