iframe-proxy | Sunbelt Computer Software

55 lines (37 loc) · 1.21 KB

# encoding: utf-8
from webob import Response
from random import randint
from time import sleep
from waitress import serve
from concurrent.futures import ThreadPoolExecutor, as_completed, TimeoutError
def mul(x, y):
	sleep(0.125)
	return ('text/plain', "{0} * {1} = {2}\n".format(x, y, x * y))
executor = ThreadPoolExecutor(10)
def app(environ, start_response):
	"""Multipart AJAX request example.
	See: http://test.getify.com/mpAjax/description.html
	response = Response()
	parts = []
	for i in range(12):
		for j in range(12):
			parts.append(executor.submit(mul, i, j))
	def stream(parts, timeout=None):
			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(environ, start_response)
if __name__ == '__main__':
	serve(app, host='127.0.0.1', port=8080, threads=4)

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

stream2.py

Latest commit

History

stream2.py

File metadata and controls