Swallow Exceptions when receiver.close()

opensource4you · Aug 22, 2022 · 2dae423 · 2dae423
1 parent 2deec7d
commit 2dae423
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/app/src/main/java/org/astraea/app/performance/TrackerThread.java b/app/src/main/java/org/astraea/app/performance/TrackerThread.java
@@ -191,8 +191,8 @@ public boolean closed() {
       public void close() {
         closed.set(true);
         waitForDone();
-        producerReceiver.close();
-        consumerReceiver.close();
+        Utils.packException(producerReceiver::close);
+        Utils.packException(consumerReceiver::close);
       }
     };
   }