From c2302d86f9ff463505d51d39ddd8baf51ceba498 Mon Sep 17 00:00:00 2001 From: Jonathan Cobb Date: Fri, 10 Jan 2020 10:14:36 -0500 Subject: [PATCH] set error if interrupted --- .../src/main/java/bubble/service/dbfilter/EntityIterator.java | 1 + 1 file changed, 1 insertion(+) diff --git a/bubble-server/src/main/java/bubble/service/dbfilter/EntityIterator.java b/bubble-server/src/main/java/bubble/service/dbfilter/EntityIterator.java index 79ae6e6c..23f932be 100644 --- a/bubble-server/src/main/java/bubble/service/dbfilter/EntityIterator.java +++ b/bubble-server/src/main/java/bubble/service/dbfilter/EntityIterator.java @@ -48,6 +48,7 @@ public abstract class EntityIterator implements Iterator { try { return queue.take(); } catch (InterruptedException e) { + error.set(e); return die("next: queue.take interrupted"); } }