()
| 1500 | # Buffered streams |
| 1501 | |
| 1502 | def test_buffered_input_stream(): |
| 1503 | raw = pa.BufferReader(b"123456789") |
| 1504 | f = pa.BufferedInputStream(raw, buffer_size=4) |
| 1505 | assert f.read(2) == b"12" |
| 1506 | assert raw.tell() == 4 |
| 1507 | f.close() |
| 1508 | assert f.closed |
| 1509 | assert raw.closed |
| 1510 | |
| 1511 | |
| 1512 | def test_buffered_input_stream_detach_seekable(): |
nothing calls this directly
no test coverage detected