Fix tests

4 years ago · beda1105e8
1 changed files with 6 additions and 1 deletions
--- a/common/util/src/main/java/org/thingsboard/common/util/ListeningExecutor.java
+++ b/common/util/src/main/java/org/thingsboard/common/util/ListeningExecutor.java
@ -24,7 +24,12 @@ public interface ListeningExecutor extends Executor {

    <T> ListenableFuture<T> executeAsync(Callable<T> task);

-    ListenableFuture<?> executeAsync(Runnable task);
+    default ListenableFuture<?> executeAsync(Runnable task) {
+        return executeAsync(() -> {
+            task.run();
+            return null;
+        });
+    }

    default <T> ListenableFuture<T> submit(Callable<T> task) {
        return executeAsync(task);