# Path: xudd/actor.py
# def autoreply(func):
#     def wrapper(self, message):
#     def __init__(self, hive, id):
#     def handle_message(self, message):
#     def _handle_coroutine_result(self, coroutine_result, original_coroutine):
#             def asyncio_resume(future):
#     def send_message(self, *args, **kwargs):
#     def wait_on_message(self, to, directive, from_id=None,
#                         id=None, body=None, in_reply_to=None):
#     def wait_on_self(self):
#     def wait_on_future(self, future):
#         def _message_return(future):
#     def __init__(self, actor_id):
# class Actor(object):
# class ActorProxy(object):


import logging
import urlparse
import sys
    from io import BytesIO # python 3
    from cStringIO import StringIO as BytesIO # python 2
from tornado import escape
from xudd.actor import Actor, super_init

try:
except ImportError:




_log = logging.getLogger(__name__)



# Path: xudd/actor.py
# def autoreply(func):
#     def wrapper(self, message):
#     def __init__(self, hive, id):
#     def handle_message(self, message):
#     def _handle_coroutine_result(self, coroutine_result, original_coroutine):
#             def asyncio_resume(future):
#     def send_message(self, *args, **kwargs):
#     def wait_on_message(self, to, directive, from_id=None,
#                         id=None, body=None, in_reply_to=None):
#     def wait_on_self(self):
#     def wait_on_future(self, future):
#         def _message_return(future):
#     def __init__(self, actor_id):
# class Actor(object):
# class ActorProxy(object):


# Path: xudd/lib/wsgi.py
import logging
import urlparse
import sys
    from io import BytesIO # python 3
    from cStringIO import StringIO as BytesIO # python 2
from tornado import escape
from xudd.actor import Actor, super_init


try:
except ImportError:




_log = logging.getLogger(__name__)



class WSGI(Actor):