Merged with the default branch.1.13.0-1

1 files changed, 25 insertions, 0 deletions

diff --git a/test/python/delayed/wsgi.py b/test/python/delayed/wsgi.py
new file mode 100644
index 00000000..d25e2765
--- /dev/null
+++ b/test/python/delayed/wsgi.py
@@ -0,0 +1,25 @@
+import time
+
+
+def application(environ, start_response):
+    parts = int(environ.get('HTTP_X_PARTS', 1))
+    delay = int(environ.get('HTTP_X_DELAY', 0))
+
+    content_length = int(environ.get('CONTENT_LENGTH', 0))
+    body = bytes(environ['wsgi.input'].read(content_length))
+
+    write = start_response('200', [('Content-Length', str(len(body)))])
+
+    if not body:
+        return []
+
+    step = int(len(body) / parts)
+    for i in range(0, len(body), step):
+        try:
+            write(body[i : i + step])
+        except:
+            break
+
+        time.sleep(delay)
+
+    return []