Skip to content

Commit

Permalink
fix end of record detection logic when sending ResultSet by multiple …
Browse files Browse the repository at this point in the history
…writers
  • Loading branch information
t-horikawa committed Jun 18, 2024
1 parent 7bea73f commit 489fe26
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion modules/ipc/src/main/native/include/wire.h
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 489fe26

Please sign in to comment.