Attempt to use pulsar to do rpc and async download concurrently

manage.py

import asyncio
from pulsar.apps import rpc, wsgi
from pulsar.utils.httpurl import JSON_CONTENT_TYPES


@asyncio.coroutine
def long_download(request, delay=1):
    print('sleeping for: {0} seconds'.format(delay))
    yield from asyncio.sleep(delay)
    print('{0} seconds task is finished'.format(delay))


class MyRpc(rpc.JSONRPC):

    def rpc_ping(self, request):
        return 'pong'

    rpc_long_download = rpc.rpc_method(long_download)


class Site(wsgi.LazyWsgi):
    '''WSGI handler for the RPC server'''
    def setup(self, environ):
        '''Called once to setup the list of wsgi middleware.'''
        middleware = wsgi.Router('/', post=MyRpc(),
                                 accept_content_types=JSON_CONTENT_TYPES)
        response = [wsgi.GZipMiddleware(200)]
        return wsgi.WsgiHandler(middleware=[wsgi.wait_for_body_middleware,
                                            middleware],
                                response_middleware=response,
                                async=True)


def server(callable=None, **params):
    return wsgi.WSGIServer(Site(), **params)


if __name__ == '__main__':  # pragma nocover
    server().start()