(file_fixture, tmpdir)
| 225 | |
| 226 | |
| 227 | def test_file_pathlib(file_fixture, tmpdir): |
| 228 | file_fixture.write_batches() |
| 229 | source = file_fixture.get_source() |
| 230 | |
| 231 | path = tmpdir.join('file.arrow').strpath |
| 232 | with open(path, 'wb') as f: |
| 233 | f.write(source) |
| 234 | |
| 235 | t1 = pa.ipc.open_file(pathlib.Path(path)).read_all() |
| 236 | t2 = pa.ipc.open_file(pa.OSFile(path)).read_all() |
| 237 | |
| 238 | assert t1.equals(t2) |
| 239 | |
| 240 | |
| 241 | def test_empty_stream(): |
nothing calls this directly
no test coverage detected