ClojureScript

Promise 交互

直接使用 JavaScript promises

Promises 是在 JavaScript 中处理异步操作的常用方式。你可以通过调用 promise 方法,在 ClojureScript 中轻松使用它们。

JavaScript

Promise.resolve(42)
  .then(val => console.log(val));

ClojureScript

(.then (js/Promise.resolve 42)
       #(js/console.log %))

但是,在 ClojureScript 中链式 promise 方法会导致代码级联。使用 thread-first 宏,我们可以回到更优雅的代码。

JavaScript

Promise.resolve(42)
  .then(val => console.log(val))
  .catch(err => console.log(err))
  .finally(() => console.log('cleanup'));

ClojureScript

(.finally
  (.catch
  (.then (js/Promise.resolve 42)
          #(js/console.log %))
  #(js/console.log %))
  #(js/console.log "cleanup"))

; same as above
(-> (js/Promise.resolve 42)
    (.then #(js/console.log %))
    (.catch #(js/console.log %))
    (.finally #(js/console.log "cleanup")))

使用 await 的 promise 密集型代码会产生更复杂的代码结构,并不太友好。例如,来自 Puppeteer 用法 中的这个示例

JavaScript

const puppeteer = require('puppeteer');

(async () => {
  const browser = await puppeteer.launch();
  const page = await browser.newPage();
  try {
    await page.goto('https://example.com');
    await page.screenshot({path: 'example.png'});
  } catch (err) {
    console.log(err);
  }

  await browser.close();
})();

ClojureScript

(def puppeteer (js/require "puppeteer"))

(-> (.launch puppeteer)
    (.then (fn [browser]
             (-> (.newPage browser)
                 (.then (fn [page]
                          (-> (.goto page "https://clojure.org")
                              (.then #(.screenshot page #js{:path "screenshot.png"}))
                              (.catch #(js/console.log %))
                              (.then #(.close browser)))))))))

为了控制这种类型的代码,我们转向 core.async

使用 core.async 与 Promises

ClojureScript 在 core.async 中提供了出色的异步编程功能。一个特别方便的工具是 <p! 宏,它在 go 内使用一个 promise。

使用 go 块允许我们编写看起来是同步的代码,即使它实际上是异步的,就像 JavaScript 中的 awaitasync 一样。

ClojureScript

(:require
   [cljs.core.async :refer [go]]
   [cljs.core.async.interop :refer-macros [<p!]])

(def puppeteer (js/require "puppeteer"))

(go
  (let [browser (<p! (.launch puppeteer))
        page (<p! (.newPage browser))]
    (try
      (<p! (.goto page "https://clojure.org"))
      (<p! (.screenshot page #js{:path "screenshot.png"}))
      (catch js/Error err (js/console.log (ex-cause err))))
    (.close browser)))

这只是触及表面。core.async 提供了非常强大的队列式通道,可以做的事情远不止处理一次性 promises。

你可以在 仓库原理代码演练博客文章 中了解有关 core-async 的更多信息。

原作者:Filipe Silva