From 489fe261ba3e64565014ae582279488bd8f6d4cb Mon Sep 17 00:00:00 2001
From: t-horikawa <horikawa@nautilus-technologies.com>
Date: Tue, 18 Jun 2024 20:19:00 +0900
Subject: [PATCH] fix end of record detection logic when sending ResultSet by
 multiple writers

---
 modules/ipc/src/main/native/include/wire.h | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/modules/ipc/src/main/native/include/wire.h b/modules/ipc/src/main/native/include/wire.h
index 598391ac..ea9ac141 100644
--- a/modules/ipc/src/main/native/include/wire.h
+++ b/modules/ipc/src/main/native/include/wire.h
@@ -896,7 +896,10 @@ class unidirectional_simple_wires {
      *  used by client
      */
     [[nodiscard]] bool is_eor() const {
-        return eor_;
+        if (!eor_) {
+            return false;
+        }
+        return std::all_of(unidirectional_simple_wires_.begin(), unidirectional_simple_wires_.end(), [](const unidirectional_simple_wire& wire) { return !wire.has_record(); });
     }
 
 private: