()
| 968 | |
| 969 | |
| 970 | def test_memory_output_stream(): |
| 971 | # 10 bytes |
| 972 | val = b'dataabcdef' |
| 973 | f = pa.BufferOutputStream() |
| 974 | |
| 975 | K = 1000 |
| 976 | for i in range(K): |
| 977 | f.write(val) |
| 978 | |
| 979 | buf = f.getvalue() |
| 980 | assert len(buf) == len(val) * K |
| 981 | assert buf.to_pybytes() == val * K |
| 982 | |
| 983 | |
| 984 | def test_inmemory_write_after_closed(): |
nothing calls this directly
no test coverage detected