In #37797 we added the dunder methods for the Arrow PyCapsule Protocol, and we also already added support for checking for objects that implement the protocol in the pa.array(..), pa.record_batch(..) and pa.schema(..) constructors, such that you can for example create a pyarrow array with pa.array(obj) given any object obj that supports the interface by defining __arrow_c_array__.
But for the stream objects, we don't have an equivalent factory function that creates a RecordBatchReader. Therefore I think it would be good to add a public RecordBatchReader constructor from stream objects implementing the protocol (to avoid you need to call the _import_from_c_capsule private method for this use case). For example RecordBatchReader.from_stream?
In #37797 we added the dunder methods for the Arrow PyCapsule Protocol, and we also already added support for checking for objects that implement the protocol in the
pa.array(..),pa.record_batch(..)andpa.schema(..)constructors, such that you can for example create a pyarrow array withpa.array(obj)given any objectobjthat supports the interface by defining__arrow_c_array__.But for the stream objects, we don't have an equivalent factory function that creates a RecordBatchReader. Therefore I think it would be good to add a public RecordBatchReader constructor from stream objects implementing the protocol (to avoid you need to call the
_import_from_c_capsuleprivate method for this use case). For exampleRecordBatchReader.from_stream?