# Path: pymco/listener.py
# LOG = logging.getLogger(__name__)
# class CurrentHostPortListener(listener.ConnectionListener):
# class ResponseListener(listener.ConnectionListener):
#     def __init__(self, *args, **kwargs):
#     def on_connecting(self, host_and_port):
#     def get_host(self):
#     def get_port(self):
#     def __init__(self, config, connector, count, timeout=30, condition=None,
#                  logger=LOG):
#     def security(self):
#     def on_message(self, headers, body):
#     def wait_on_message(self):
#     def _wait_loop(self, timeout):
# 
# Path: pymco/test/utils.py
# def get_template(name, package=__package__):
# def configfile(ctxt=None):


from yaml import scanner
from pymco import listener
from pymco.test.utils import mock
import pytest
"""



@pytest.fixture
def condition():
    return mock.Mock()


@pytest.fixture
def connector():
    return mock.Mock()


@pytest.fixture
def logger():
    return mock.Mock()


@pytest.fixture
def result_listener(config, condition, connector, logger):
    return listener.ResponseListener(config,
                                     logger=logger,
                                     connector=connector,
                                     condition=condition,
                                     count=2)


@pytest.fixture
def track_listener():

# Path: pymco/listener.py
# LOG = logging.getLogger(__name__)
# class CurrentHostPortListener(listener.ConnectionListener):
# class ResponseListener(listener.ConnectionListener):
#     def __init__(self, *args, **kwargs):
#     def on_connecting(self, host_and_port):
#     def get_host(self):
#     def get_port(self):
#     def __init__(self, config, connector, count, timeout=30, condition=None,
#                  logger=LOG):
#     def security(self):
#     def on_message(self, headers, body):
#     def wait_on_message(self):
#     def _wait_loop(self, timeout):
# 
# Path: pymco/test/utils.py
# def get_template(name, package=__package__):
# def configfile(ctxt=None):


# Path: tests/unit/test_listener.py
from yaml import scanner
from pymco import listener
from pymco.test.utils import mock
import pytest

"""



@pytest.fixture
def condition():
    return mock.Mock()


@pytest.fixture
def connector():
    return mock.Mock()


@pytest.fixture
def logger():
    return mock.Mock()


@pytest.fixture
def result_listener(config, condition, connector, logger):
    return listener.ResponseListener(config,
                                     logger=logger,
                                     connector=connector,
                                     condition=condition,
                                     count=2)


@pytest.fixture
def track_listener():

    return listener.CurrentHostPortListener()