summaryrefslogtreecommitdiffhomepage
path: root/test/python/delayed
diff options
context:
space:
mode:
authorAndrei Belov <defan@nginx.com>2021-05-27 17:03:24 +0300
committerAndrei Belov <defan@nginx.com>2021-05-27 17:03:24 +0300
commit0afb4b5790c5a37ba6b880eb351a65fe00521fbe (patch)
treec7e0b6bed92ee62a5e8b13c945c4134e68554cec /test/python/delayed
parent21ff5e086ece7188df3b7338d228fa4fb7f886af (diff)
parentd06e55dfa3692e27a92ff6c2534bb083416bc0c8 (diff)
downloadunit-0afb4b5790c5a37ba6b880eb351a65fe00521fbe.tar.gz
unit-0afb4b5790c5a37ba6b880eb351a65fe00521fbe.tar.bz2
Merged with the default branch.1.24.0-1
Diffstat (limited to 'test/python/delayed')
-rw-r--r--test/python/delayed/asgi.py27
1 files changed, 15 insertions, 12 deletions
diff --git a/test/python/delayed/asgi.py b/test/python/delayed/asgi.py
index d5cad929..1cb15a92 100644
--- a/test/python/delayed/asgi.py
+++ b/test/python/delayed/asgi.py
@@ -1,5 +1,6 @@
import asyncio
+
async def application(scope, receive, send):
assert scope['type'] == 'http'
@@ -28,13 +29,13 @@ async def application(scope, receive, send):
loop.call_later(n, future.set_result, None)
await future
- await send({
- 'type': 'http.response.start',
- 'status': 200,
- 'headers': [
- (b'content-length', str(len(body)).encode()),
- ]
- })
+ await send(
+ {
+ 'type': 'http.response.start',
+ 'status': 200,
+ 'headers': [(b'content-length', str(len(body)).encode()),],
+ }
+ )
if not body:
await sleep(delay)
@@ -42,10 +43,12 @@ async def application(scope, receive, send):
step = int(len(body) / parts)
for i in range(0, len(body), step):
- await send({
- 'type': 'http.response.body',
- 'body': body[i : i + step],
- 'more_body': True,
- })
+ await send(
+ {
+ 'type': 'http.response.body',
+ 'body': body[i : i + step],
+ 'more_body': True,
+ }
+ )
await sleep(delay)