def METHOD_NAME(tmpdir):
    df = vaex.from_arrays(x=[1,2])
    f = vaex.file.asyncio.WriteStream()
    def writer():
        with f:
            df.export_arrow(f)
    threading.Thread(target=writer, daemon=True).start()
    path = tmpdir / '1.arrow'
    with open(path, 'wb') as fdisk:
        for chunk in f:
            fdisk.write(chunk)
    df_disk = vaex.open(path)
    assert df_disk.x.tolist() == [1, 2]