# Path: sio/workers/runner.py
# def _run_filters(key, environ):
# def _add_meta(environ):
# def _save_failure(exc, environ):
# def _print_environ(environ):
# def run(environ):
# def main():
# 
# Path: sio/protocol/rpc.py
# class TimeoutError(Exception):
# class ProtocolError(Exception):
# class RemoteError(Exception):
# class NoSuchMethodError(RemoteError):
# class WorkerRPC(NetstringReceiver):
#     def __init__(self, err, tb=None, uid=None):
#     def __init__(self, err=None, uid=None):
# def makeRemoteException(msg, uid=None):
#     def __init__(self, server=False, timeout=DEFAULT_TIMEOUT):
#     def connectionMade(self):
#     def connectionLost(self, reason):
#     def _processMessage(self, msg):
#     def getHelloData(self):
#     def stringReceived(self, string):
#     def _reply(self, value, request=None):
#     def _replyError(self, err, request=None):
#     def _timeout(self, rid):
#     def sendMsg(self, msg_type, **kwargs):
#     def call(self, cmd, *args, **kwargs):
#         def cb(ignore):
#     MAX_LENGTH = 2 ** 20  # 1MB should be enough
#     DEFAULT_TIMEOUT = 30


from twisted.internet.protocol import ReconnectingClientFactory
from twisted.internet import threads
from sio.workers import runner
from sio.protocol import rpc
from twisted.logger import Logger, LogLevel
import platform
import six
from __future__ import absolute_import

log = Logger()

# ingen replaces the environment, so merge it
def _runner_wrap(env):
    renv = runner.run(env)
    env.update(renv)
    return env


class WorkerProtocol(rpc.WorkerRPC):
    def __init__(self):

# Path: sio/workers/runner.py
# def _run_filters(key, environ):
# def _add_meta(environ):
# def _save_failure(exc, environ):
# def _print_environ(environ):
# def run(environ):
# def main():
# 
# Path: sio/protocol/rpc.py
# class TimeoutError(Exception):
# class ProtocolError(Exception):
# class RemoteError(Exception):
# class NoSuchMethodError(RemoteError):
# class WorkerRPC(NetstringReceiver):
#     def __init__(self, err, tb=None, uid=None):
#     def __init__(self, err=None, uid=None):
# def makeRemoteException(msg, uid=None):
#     def __init__(self, server=False, timeout=DEFAULT_TIMEOUT):
#     def connectionMade(self):
#     def connectionLost(self, reason):
#     def _processMessage(self, msg):
#     def getHelloData(self):
#     def stringReceived(self, string):
#     def _reply(self, value, request=None):
#     def _replyError(self, err, request=None):
#     def _timeout(self, rid):
#     def sendMsg(self, msg_type, **kwargs):
#     def call(self, cmd, *args, **kwargs):
#         def cb(ignore):
#     MAX_LENGTH = 2 ** 20  # 1MB should be enough
#     DEFAULT_TIMEOUT = 30


# Path: sio/protocol/worker.py
from twisted.internet.protocol import ReconnectingClientFactory
from twisted.internet import threads
from sio.workers import runner
from sio.protocol import rpc
from twisted.logger import Logger, LogLevel
import platform
import six

from __future__ import absolute_import

log = Logger()

# ingen replaces the environment, so merge it
def _runner_wrap(env):
    renv = runner.run(env)
    env.update(renv)
    return env


class WorkerProtocol(rpc.WorkerRPC):
    def __init__(self):

        rpc.WorkerRPC.__init__(self, server=False)