async def METHOD_NAME(self):
    queue = BasicMessageQueue()
    queue.stop()
    with self.assertRaises(asyncio.CancelledError):
        await queue.dequeue(timeout=0)
    test_value = "test value"
    with self.assertRaises(asyncio.CancelledError):
        await queue.enqueue(test_value)
    results = asyncio.wait_for(collect(queue), timeout=1.0)
    assert await results == []
    with self.assertRaises(asyncio.CancelledError):
        await queue.dequeue(timeout=0)
    queue.reset()
    results = asyncio.wait_for(collect(queue), timeout=1.0)
    await queue.enqueue(test_value)
    found = await results
    assert found == [test_value]