This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-nanoarrow.git


The following commit(s) were added to refs/heads/main by this push:
     new 705dc5d  ipc: Update dist/ for commit 
373744c299d4df8a38cfe745724cbfe4f062d9c5
705dc5d is described below

commit 705dc5d4190cab261d915861f7c43e241711bd16
Author: GitHub Actions <[email protected]>
AuthorDate: Mon Mar 27 18:23:44 2023 +0000

    ipc: Update dist/ for commit 373744c299d4df8a38cfe745724cbfe4f062d9c5
---
 dist/nanoarrow_ipc.c | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git a/dist/nanoarrow_ipc.c b/dist/nanoarrow_ipc.c
index 07a9b2e..c783dcb 100644
--- a/dist/nanoarrow_ipc.c
+++ b/dist/nanoarrow_ipc.c
@@ -22021,12 +22021,6 @@ static int ArrowIpcArrayStreamReaderGetNext(struct 
ArrowArrayStream* stream,
                                             struct ArrowArray* out) {
   struct ArrowIpcArrayStreamReaderPrivate* private_data =
       (struct ArrowIpcArrayStreamReaderPrivate*)stream->private_data;
-  // Check if we are all done
-  if (private_data->input.release == NULL) {
-    out->release = NULL;
-    return NANOARROW_OK;
-  }
-
   private_data->error.message[0] = '\0';
   
NANOARROW_RETURN_NOT_OK(ArrowIpcArrayStreamReaderReadSchemaIfNeeded(private_data));
 
@@ -22034,8 +22028,8 @@ static int ArrowIpcArrayStreamReaderGetNext(struct 
ArrowArrayStream* stream,
   int result = ArrowIpcArrayStreamReaderNextHeader(
       private_data, NANOARROW_IPC_MESSAGE_TYPE_RECORD_BATCH);
   if (result == ENODATA) {
-    // If the stream is finished, release the input
-    private_data->input.release(&private_data->input);
+    // Stream is finished either because there is no input or because
+    // end of stream bytes were read.
     out->release = NULL;
     return NANOARROW_OK;
   }

Reply via email to