# Path: pq/api.py



import unittest
from asyncio import Future
from pulsar.api import send
from pulsar.utils.string import random_string
from pq import api
"""Tests connection errors"""




class Tester:

    def __init__(self):
        self.end = Future()

    def __call__(self, *args, **kwargs):
        if not self.end.done():
            self.end.set_result((args, kwargs))


class TestConnectionDrop(unittest.TestCase):
    app = None

    async def setUp(self):

# Path: pq/api.py



# Path: tests/test_connection.py
import unittest
from asyncio import Future
from pulsar.api import send
from pulsar.utils.string import random_string
from pq import api

"""Tests connection errors"""




class Tester:

    def __init__(self):
        self.end = Future()

    def __call__(self, *args, **kwargs):
        if not self.end.done():
            self.end.set_result((args, kwargs))


class TestConnectionDrop(unittest.TestCase):
    app = None

    async def setUp(self):

        self.app = api.QueueApp(