gistfile1.py

import io
from webob.request import Request


class Application:

    def __init__(self, app):
        self._app = app

    def __call__(self, environ, start_response):
        request = Request(environ)

        # make 'wsgi.input' synchronous
        if (request.method in ('POST', 'PUT') and
            request.content_type in ('application/x-www-form-urlencoded',
                                     'multipart/form-data')):
            wsgiinput = io.BytesIO()
            try:
                while True:
                    wsgiinput.write((yield from environ['wsgi.input'].read()))
            except aiohttp.EofStream:
                pass
            wsgiinput.seek(0)
            environ['wsgi.input'] = wsgiinput

        return self._app(environ, start_response)