summaryrefslogtreecommitdiff
path: root/platform/core-api/src/com/intellij/util/ArrayQuery.java
diff options
context:
space:
mode:
Diffstat (limited to 'platform/core-api/src/com/intellij/util/ArrayQuery.java')
-rw-r--r--platform/core-api/src/com/intellij/util/ArrayQuery.java11
1 files changed, 2 insertions, 9 deletions
diff --git a/platform/core-api/src/com/intellij/util/ArrayQuery.java b/platform/core-api/src/com/intellij/util/ArrayQuery.java
index abe2f1001fe0..1b7760146de6 100644
--- a/platform/core-api/src/com/intellij/util/ArrayQuery.java
+++ b/platform/core-api/src/com/intellij/util/ArrayQuery.java
@@ -17,8 +17,7 @@
package com.intellij.util;
import com.intellij.concurrency.AsyncFuture;
-import com.intellij.concurrency.AsyncFutureFactory;
-import com.intellij.concurrency.AsyncFutureResult;
+import com.intellij.concurrency.AsyncUtil;
import com.intellij.util.containers.ContainerUtil;
import org.jetbrains.annotations.NotNull;
@@ -55,13 +54,7 @@ public class ArrayQuery<T> implements Query<T> {
@NotNull
@Override
public AsyncFuture<Boolean> forEachAsync(@NotNull final Processor<T> consumer) {
- final AsyncFutureResult<Boolean> result = AsyncFutureFactory.getInstance().createAsyncFutureResult();
- try {
- result.set(forEach(consumer));
- } catch (Throwable t){
- result.setException(t);
- }
- return result;
+ return AsyncUtil.wrapBoolean(forEach(consumer));
}