From 2c6852ecf9fb97bf4eedaac204a494c2f500a359 Mon Sep 17 00:00:00 2001 From: Doug Hoyte Date: Fri, 19 May 2023 15:15:47 -0400 Subject: [PATCH] bugfix for when limit=0 --- src/DBQuery.h | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/DBQuery.h b/src/DBQuery.h index e4cbdfe..2f2475d 100644 --- a/src/DBQuery.h +++ b/src/DBQuery.h @@ -324,6 +324,8 @@ struct DBQuery : NonCopyable { uint64_t startTime = hoytech::curr_time_us(); bool complete = scanner->scan(txn, [&](uint64_t levId, std::string_view eventPayload){ + if (f.limit == 0) return true; + // If this event came in after our query began, don't send it. It will be sent after the EOSE. if (levId > sub.latestEventId) return false;