(stream_fixture, options)
| 311 | pa.ipc.IpcReadOptions(use_threads=False), |
| 312 | ]) |
| 313 | def test_open_stream_options(stream_fixture, options): |
| 314 | stream_fixture.write_batches() |
| 315 | source = stream_fixture.get_source() |
| 316 | |
| 317 | reader = pa.ipc.open_stream(source, options=options) |
| 318 | |
| 319 | reader.read_all() |
| 320 | st = reader.stats |
| 321 | assert st.num_messages == 6 |
| 322 | assert st.num_record_batches == 5 |
| 323 | |
| 324 | assert tuple(st) == tuple(stream_fixture.write_stats) |
| 325 | |
| 326 | |
| 327 | def test_open_stream_with_wrong_options(stream_fixture): |
nothing calls this directly
no test coverage detected