# Path: sio/workers/util.py
# def json_dumps(obj, **kwargs):
#     """Python 3 and 2 compatible json.dump."""
#     kwargs.setdefault('cls', CompatibleJSONEncoder)
#     return json.dumps(obj, **kwargs)


from twisted.protocols.basic import NetstringReceiver
from twisted.internet import defer, reactor
from twisted.logger import Logger
from enum import Enum
from sio.workers.util import json_dumps
import six
import json
from __future__ import absolute_import

log = Logger()




State = Enum('State', 'connected sent_hello established')


class TimeoutError(Exception):
    pass


class ProtocolError(Exception):

# Path: sio/workers/util.py
# def json_dumps(obj, **kwargs):
#     """Python 3 and 2 compatible json.dump."""
#     kwargs.setdefault('cls', CompatibleJSONEncoder)
#     return json.dumps(obj, **kwargs)


# Path: sio/protocol/rpc.py
from twisted.protocols.basic import NetstringReceiver
from twisted.internet import defer, reactor
from twisted.logger import Logger
from enum import Enum
from sio.workers.util import json_dumps
import six
import json

from __future__ import absolute_import

log = Logger()




State = Enum('State', 'connected sent_hello established')


class TimeoutError(Exception):
    pass


class ProtocolError(Exception):

    pass