WebCore/docs/example/stream.html at develop · marrow/WebCore

Repository navigation

History

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

<!DOCTYPE html>

<html>

<head>

<title>stream.py</title>

</head>

<body>

<thead>

<tr>

<h1>stream.py</h1>

</th>

</th>

</tr>

</thead>

<tbody>

</div>

</td>

<div class="highlight"><pre>from random import randint

from time import sleep

from concurrent.futures import ThreadPoolExecutor, as_completed, TimeoutError

</pre></div>

</td>

</tr>

</div>

</td>

<div class="highlight"><pre>def mul(x, y):

sleep(0.125)

return ('text/plain', "{0} * {1} = {2}\n".format(x, y, x * y))

executor = ThreadPoolExecutor(10)

</pre></div>

</td>

</tr>

</div>

Multipart AJAX request example.

See: http://test.getify.com/mpAjax/description.html

</td>

<div class="highlight"><pre>def root(context):

response = context.response

parts = []

for i in range(12):

for j in range(12):

parts.append(executor.submit(mul, i, j))

</pre></div>

</td>

</tr>

</div>

</td>

<div class="highlight"><pre> def stream(parts, timeout=None):

try:

for future in as_completed(parts, timeout):

mime, result = future.result()

result = result.encode('utf8')

yield "!!!!!!=_NextPart_{num}\nContent-Type: {mime}\nContent-Length: {length}\n\n".format(

num = randint(100000000, 999999999),

mime = mime,

length = len(result)

).encode('utf8') + result

except TimeoutError:

for future in parts:

future.cancel()

response.content_length = None

response.app_iter = stream(parts, 0.2)

return response

if __name__ == '__main__':

from web.core import Application

</pre></div>

</td>

</tr>

</div>

wsgiref streams the chunks correctly, waitress buffers in 18000 byte chunks.

</td>

<div class="highlight"><pre> Application(root, logging={'level': 'debug'}).serve('waitress', send_bytes=1)

</pre></div>

</td>

</tr>

</tbody>

</table>

Generated by <a href="http://mccutchen.github.com/dycco/">Dycco</a>.

Last updated 25 Apr 2016.

</footer>

</div>

</body>

</html>

FilesExpand file tree

stream.html

Latest commit

History

stream.html

File metadata and controls