summaryrefslogtreecommitdiff
path: root/platform/core-api/src/com/intellij/util/CollectionQuery.java
diff options
context:
space:
mode:
Diffstat (limited to 'platform/core-api/src/com/intellij/util/CollectionQuery.java')
-rw-r--r--platform/core-api/src/com/intellij/util/CollectionQuery.java13
1 files changed, 3 insertions, 10 deletions
diff --git a/platform/core-api/src/com/intellij/util/CollectionQuery.java b/platform/core-api/src/com/intellij/util/CollectionQuery.java
index cd90ab55edd9..253182cef0c1 100644
--- a/platform/core-api/src/com/intellij/util/CollectionQuery.java
+++ b/platform/core-api/src/com/intellij/util/CollectionQuery.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2000-2009 JetBrains s.r.o.
+ * Copyright 2000-2014 JetBrains s.r.o.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -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 CollectionQuery<T> implements Query<T> {
@NotNull
@Override
public AsyncFuture<Boolean> forEachAsync(@NotNull Processor<T> consumer) {
- AsyncFutureResult<Boolean> result = AsyncFutureFactory.getInstance().createAsyncFutureResult();
- try {
- result.set(forEach(consumer));
- } catch (Throwable t) {
- result.setException(t);
- }
- return result;
+ return AsyncUtil.wrapBoolean(forEach(consumer));
}
@NotNull