# Path: deepstreampy/constants/connection_state.py
# CLOSED = 'CLOSED'
# AWAITING_AUTHENTICATION = 'AWAITING_AUTHENTICATION'
# AWAITING_CONNECTION = 'AWAITING_CONNECTION'
# AUTHENTICATING = 'AUTHENTICATING'
# OPEN = 'OPEN'
# ERROR = 'ERROR'
# RECONNECTING = 'RECONNECTING'
# CHALLENGING = 'CHALLENGING'
# 
# Path: deepstreampy/client.py
# def connect(url, **options):
#     def __init__(self, url, **options):
#     def connect(self, callback=None):
#     def close(self):
#     def login(self, auth_params):
#     def _on_message(self, message):
#     def _on_error(self, topic, event, msg=None):
#     def connection_state(self):
#     def record(self):
#     def event(self):
#     def rpc(self):
#     def presence(self):
#     def io_loop(self):
# class Client(EventEmitter):
# 
# Path: tests/util.py
# def msg(value):
#     return value.replace("|", chr(31)).replace("+", chr(30)).encode()


from deepstreampy.constants import connection_state
from deepstreampy import client
from tests.util import msg
from tornado import testing
    from unittest import mock
import sys
    import mock
from __future__ import absolute_import, division, print_function, with_statement
from __future__ import unicode_literals




if sys.version_info[0] < 3:
else:

URL = "ws://localhost:7777/deepstream"


class PresenceHandlerTest(testing.AsyncTestCase):

    def setUp(self):
        super(PresenceHandlerTest, self).setUp()
        options = {"subscriptionTimeout": 0.005}

# Path: deepstreampy/constants/connection_state.py
# CLOSED = 'CLOSED'
# AWAITING_AUTHENTICATION = 'AWAITING_AUTHENTICATION'
# AWAITING_CONNECTION = 'AWAITING_CONNECTION'
# AUTHENTICATING = 'AUTHENTICATING'
# OPEN = 'OPEN'
# ERROR = 'ERROR'
# RECONNECTING = 'RECONNECTING'
# CHALLENGING = 'CHALLENGING'
# 
# Path: deepstreampy/client.py
# def connect(url, **options):
#     def __init__(self, url, **options):
#     def connect(self, callback=None):
#     def close(self):
#     def login(self, auth_params):
#     def _on_message(self, message):
#     def _on_error(self, topic, event, msg=None):
#     def connection_state(self):
#     def record(self):
#     def event(self):
#     def rpc(self):
#     def presence(self):
#     def io_loop(self):
# class Client(EventEmitter):
# 
# Path: tests/util.py
# def msg(value):
#     return value.replace("|", chr(31)).replace("+", chr(30)).encode()


# Path: tests/test_presence.py
from deepstreampy.constants import connection_state
from deepstreampy import client
from tests.util import msg
from tornado import testing
    from unittest import mock
import sys
    import mock

from __future__ import absolute_import, division, print_function, with_statement
from __future__ import unicode_literals




if sys.version_info[0] < 3:
else:

URL = "ws://localhost:7777/deepstream"


class PresenceHandlerTest(testing.AsyncTestCase):

    def setUp(self):
        super(PresenceHandlerTest, self).setUp()
        options = {"subscriptionTimeout": 0.005}

        self.client = client.Client(URL, **options)