(schema, batches)
| 443 | |
| 444 | |
| 445 | def make_ipc_stream_reader(schema, batches): |
| 446 | return pa.ipc.open_stream(make_serialized(schema, batches)) |
| 447 | |
| 448 | |
| 449 | def make_py_record_batch_reader(schema, batches): |
nothing calls this directly
no test coverage detected