Replaced writing stream lifetime with non-static lifetime (#471)

jorgecarleitao · Sep 30, 2021 · b78eeb7 · b78eeb7
1 parent 2db7f57
commit b78eeb7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/io/parquet/write/stream.rs b/src/io/parquet/write/stream.rs
@@ -24,7 +24,7 @@ pub async fn write_stream<'a, W, I>(
 ) -> Result<u64>
 where
     W: std::io::Write,
-    I: Stream<Item = Result<RowGroupIter<'static, ArrowError>>>,
+    I: Stream<Item = Result<RowGroupIter<'a, ArrowError>>>,
 {
     let key_value_metadata = key_value_metadata
         .map(|mut x| {
@@ -56,7 +56,7 @@ pub async fn write_stream_stream<'a, W, I>(
 ) -> Result<u64>
 where
     W: futures::io::AsyncWrite + Unpin + Send,
-    I: Stream<Item = Result<RowGroupIter<'static, ArrowError>>>,
+    I: Stream<Item = Result<RowGroupIter<'a, ArrowError>>>,
 {
     let key_value_metadata = key_value_metadata
         .map(|mut x| {