diff --git a/platform/platform-api/src/org/jetbrains/concurrency/DonePromise.java b/platform/platform-api/src/org/jetbrains/concurrency/DonePromise.java index 599bc44b54c3..ebcefdae4dd3 100644 --- a/platform/platform-api/src/org/jetbrains/concurrency/DonePromise.java +++ b/platform/platform-api/src/org/jetbrains/concurrency/DonePromise.java @@ -30,7 +30,7 @@ class DonePromise extends Promise implements Getter { @NotNull @Override public Promise done(@NotNull Consumer done) { - if (!AsyncPromise.isObsolete(done)) { + if (!AsyncPromiseKt.isObsolete(done)) { done.consume(result); } return this; diff --git a/platform/platform-api/src/org/jetbrains/concurrency/RejectedPromise.java b/platform/platform-api/src/org/jetbrains/concurrency/RejectedPromise.java index c45f0c57b6e7..af8d09d0746c 100644 --- a/platform/platform-api/src/org/jetbrains/concurrency/RejectedPromise.java +++ b/platform/platform-api/src/org/jetbrains/concurrency/RejectedPromise.java @@ -42,7 +42,7 @@ class RejectedPromise extends Promise { @NotNull @Override public Promise rejected(@NotNull Consumer rejected) { - if (!AsyncPromise.isObsolete(rejected)) { + if (!AsyncPromiseKt.isObsolete(rejected)) { rejected.consume(error); } return this; diff --git a/platform/platform-impl/src/org/jetbrains/concurrency/promise.kt b/platform/platform-impl/src/org/jetbrains/concurrency/promise.kt index 6219bfb59c6f..0e14060afe04 100644 --- a/platform/platform-impl/src/org/jetbrains/concurrency/promise.kt +++ b/platform/platform-impl/src/org/jetbrains/concurrency/promise.kt @@ -82,8 +82,6 @@ inline fun Promise<*>.rejected(node: Obsolescent, crossinline handler: (Throwabl fun rejectedPromise(error: String): Promise = Promise.reject(error) -fun rejectedPromise(error: Throwable): Promise = Promise.reject(error) - @Suppress("UNCHECKED_CAST") fun rejectedPromise(): Promise = rejectedPromise as Promise @@ -96,16 +94,6 @@ val Promise<*>.isPending: Boolean val Promise<*>.isFulfilled: Boolean get() = state == Promise.State.FULFILLED -inline fun AsyncPromise<*>.catchError(runnable: () -> T): T? { - try { - return runnable() - } - catch (e: Throwable) { - setError(e) - return null - } -} - fun collectResults(promises: List>): Promise> { if (promises.isEmpty()) { return resolvedPromise(emptyList()) diff --git a/platform/script-debugger/backend/src/org/jetbrains/debugger/values/ValueManager.kt b/platform/script-debugger/backend/src/org/jetbrains/debugger/values/ValueManager.kt index 9d41c63f939c..43a7120be001 100644 --- a/platform/script-debugger/backend/src/org/jetbrains/debugger/values/ValueManager.kt +++ b/platform/script-debugger/backend/src/org/jetbrains/debugger/values/ValueManager.kt @@ -15,7 +15,7 @@ */ package org.jetbrains.debugger.values -import org.jetbrains.concurrency.AsyncPromise +import org.jetbrains.concurrency.OBSOLETE_ERROR import org.jetbrains.concurrency.Obsolescent import org.jetbrains.concurrency.Promise import org.jetbrains.concurrency.rejectedPromise @@ -45,9 +45,9 @@ abstract class ValueManager() : Obsolescent { } companion object { - val OBSOLETE_CONTEXT_PROMISE = rejectedPromise(AsyncPromise.OBSOLETE_ERROR) + val OBSOLETE_CONTEXT_PROMISE = rejectedPromise(OBSOLETE_ERROR) - @Suppress("CAST_NEVER_SUCCEEDS") + @Suppress("UNCHECKED_CAST") fun reject() = OBSOLETE_CONTEXT_PROMISE as Promise } } \ No newline at end of file diff --git a/platform/script-debugger/debugger-ui/src/util.kt b/platform/script-debugger/debugger-ui/src/util.kt index 6bb7d71f1ad0..ab8df6a03ad7 100644 --- a/platform/script-debugger/debugger-ui/src/util.kt +++ b/platform/script-debugger/debugger-ui/src/util.kt @@ -1,5 +1,5 @@ /* - * Copyright 2000-2015 JetBrains s.r.o. + * Copyright 2000-2016 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. @@ -16,14 +16,14 @@ package com.intellij.xdebugger.util import com.intellij.xdebugger.XDebugSession -import org.jetbrains.concurrency.AsyncPromise +import org.jetbrains.concurrency.OBSOLETE_ERROR import org.jetbrains.concurrency.Promise import org.jetbrains.rpc.LOG // have to use package "com.intellij.xdebugger.util" to avoid package clash fun XDebugSession.rejectedErrorReporter(description: String? = null): (Throwable) -> Unit = { Promise.logError(LOG, it) - if (it != AsyncPromise.OBSOLETE_ERROR) { + if (it != OBSOLETE_ERROR) { reportError("${if (description == null) "" else description + ": "}${it.message}") } } \ No newline at end of file