From 1933f85c35b7ee60835196405538f2b886111f24 Mon Sep 17 00:00:00 2001
From: Dexter Duckworth <dexterduck@users.noreply.github.com>
Date: Thu, 17 Feb 2022 16:34:39 -0500
Subject: [PATCH] Added lifetime parameter to async IPC reader.

---
 src/io/ipc/read/stream_async.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/io/ipc/read/stream_async.rs b/src/io/ipc/read/stream_async.rs
index 9e054cd07ce..bd10ada166d 100644
--- a/src/io/ipc/read/stream_async.rs
+++ b/src/io/ipc/read/stream_async.rs
@@ -153,12 +153,12 @@ async fn maybe_next<R: AsyncRead + Unpin + Send>(
 }
 
 /// A [`Stream`] over an Arrow IPC stream that asynchronously yields [`Chunk`]s.
-pub struct AsyncStreamReader<R: AsyncRead + Unpin + Send + 'static> {
+pub struct AsyncStreamReader<'a, R: AsyncRead + Unpin + Send + 'a> {
     metadata: StreamMetadata,
-    future: Option<BoxFuture<'static, Result<Option<StreamState<R>>>>>,
+    future: Option<BoxFuture<'a, Result<Option<StreamState<R>>>>>,
 }
 
-impl<R: AsyncRead + Unpin + Send + 'static> AsyncStreamReader<R> {
+impl<'a, R: AsyncRead + Unpin + Send + 'a> AsyncStreamReader<'a, R> {
     /// Creates a new [`AsyncStreamReader`]
     pub fn new(reader: R, metadata: StreamMetadata) -> Self {
         let state = ReadState {
@@ -178,7 +178,7 @@ impl<R: AsyncRead + Unpin + Send + 'static> AsyncStreamReader<R> {
     }
 }
 
-impl<R: AsyncRead + Unpin + Send> Stream for AsyncStreamReader<R> {
+impl<'a, R: AsyncRead + Unpin + Send> Stream for AsyncStreamReader<'a, R> {
     type Item = Result<Chunk<Arc<dyn Array>>>;
 
     fn poll_next(