close() suggestion

deephaven · Apr 2, 2022 · 4781302 · 4781302
1 parent 66422bd
commit 4781302
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/engine/table/src/main/java/io/deephaven/stream/StreamToTableAdapter.java b/engine/table/src/main/java/io/deephaven/stream/StreamToTableAdapter.java
@@ -288,6 +288,8 @@ public void run() {
             final QueryTable localTable = tableRef.get();
             if (localTable != null) {
                 localTable.notifyListenersOnError(e, null);
+            } else {
+                close();
             }
         }
     }
@@ -349,6 +351,8 @@ private void doRefresh() {
             localTable.notifyListeners(new TableUpdateImpl(RowSetFactory.flat(newSize),
                     RowSetFactory.flat(oldSize), RowSetFactory.empty(),
                     RowSetShiftData.EMPTY, ModifiedColumnSet.EMPTY));
+        } else {
+            close();
         }
     }