Mark ArrowReader as Send (#60)

datafusion-contrib · Mar 5, 2024 · 6fdab55 · 6fdab55
1 parent 1489ebf
commit 6fdab55
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/arrow_reader/mod.rs b/src/arrow_reader/mod.rs
@@ -103,7 +103,7 @@ impl<R: AsyncChunkReader + 'static> ArrowReaderBuilder<R> {
 pub struct ArrowReader<R> {
     cursor: Cursor<R>,
     schema_ref: SchemaRef,
-    current_stripe: Option<Box<dyn Iterator<Item = Result<RecordBatch>>>>,
+    current_stripe: Option<Box<dyn Iterator<Item = Result<RecordBatch>> + Send>>,
     batch_size: usize,
 }