refactor: remove custom destructor for FFI_ArrowArrayStream and simplify capsule creation

Author: kosiew

src/dataframe.rs

@@ -17,7 +17,6 @@
 
 use std::collections::HashMap;
 use std::ffi::CString;
-use std::os::raw::c_void;
 use std::sync::Arc;
 
 use arrow::array::{new_null_array, RecordBatch, RecordBatchReader};
@@ -964,23 +963,9 @@ impl PyDataFrame {
         let reader: Box<dyn RecordBatchReader + Send> = Box::new(reader);
 
         let stream = FFI_ArrowArrayStream::new(reader);
-        fn drop_stream(ptr: *mut FFI_ArrowArrayStream, _ctx: *mut c_void) {
-            if ptr.is_null() {
-                return;
-            }
-            unsafe {
-                drop(Box::from_raw(ptr));
-            }
-        }
-        let stream_ptr = Box::into_raw(Box::new(stream));
         let name = CString::new("arrow_array_stream").unwrap();
-        let capsule = PyCapsule::new_bound_with_destructor(
-            py,
-            stream_ptr,
-            Some(name),
-            drop_stream as fn(*mut FFI_ArrowArrayStream, *mut c_void),
-        )
-        .map_err(py_datafusion_err)?;
+
+        let capsule = PyCapsule::new(py, stream, Some(name)).map_err(py_datafusion_err)?;
         Ok(capsule)
     }