Function close_a_pipe

tests/test_async_filelock.py:808–812

()

    closed: list[int] = []

    def close_a_pipe() -> None:
        read_fd, write_fd = os.pipe()
        os.close(read_fd)
        os.close(write_fd)
        closed.extend((read_fd, write_fd))

    with _close_after_commit(mocker, lock) as (_close_error, attempts):
        close_a_pipe()