blockingGet — do not call await if not pending

2026-09-27 10:03:11 +07:00 · 2016-11-07 17:43:57 +01:00
parent 8fd99aaaa2
commit 0112cc26f0
1 changed files with 6 additions and 4 deletions
@@ -182,10 +182,12 @@ open class AsyncPromise<T> : Promise<T>, Getter<T> {
  }

  override fun blockingGet(timeout: Int, timeUnit: TimeUnit): T? {
-    val latch = CountDownLatch(1)
-    processed { latch.countDown() }
-    if (!latch.await(timeout.toLong(), timeUnit)) {
-      throw TimeoutException()
+    if (isPending) {
+      val latch = CountDownLatch(1)
+      processed { latch.countDown() }
+      if (!latch.await(timeout.toLong(), timeUnit)) {
+        throw TimeoutException()
+      }
    }

    @Suppress("UNCHECKED_CAST")