Function wait_for_notification

tests_python/test_single_notification.py:74–84

(notification_queue, msg)

def wait_for_notification(notification_queue, msg):
    __tracebackhide__ = True
    try:
        from Queue import Empty
    except ImportError:
        from queue import Empty
    try:
        found = notification_queue.get(timeout=2)
        assert found == msg
    except Empty:
        raise AssertionError("Timed out while waiting for %s notification." % (msg,))


def join_thread(t):