Function unblocker

tests/test_waiting.py:190–195

()

            ev2.set()

    def unblocker():
        # If test doesn't pass, wake up the socket again to avoid hanging forever
        if not ev3.wait(0.5):
            assert port
            with socket.create_connection(("127.0.0.1", port)):
                pass

    t1 = spawn(writer)
    t2 = spawn(unblocker)