使用 core.async 进行测试 - 在测试中刷新 go 块?

Testing with core.async - flushing go blocks inside a test?

我正在尝试编写这样的测试:

(deftest login-form-rendering
  (async done (with-redefs [http/post fake-login-success]
        (with-mounted-component (c/login-form login!)
          (fn [c div]
            (.click (.getElementById js/document "Login"))
            (is (= (:page @app-state) :location)))))
         (done)))

我有这个模拟:

(defn fake-login-success [& _]
  (let [ch (chan)
        response {:status 200}]
    (go (>! ch response)
        ch)))

登录函数是这样做的:

(defn login! [username password]
  (go (let [result (->> {:form-params {:username @username :password @password}}
                        (http/post "/api/login")
                        (<!))
            {status :status body :body} result]
        (case status
          401 (swap! app-state assoc :page :bad-login)
          200 (swap! app-state assoc :page :location)))))

登录表单是一个试剂组件,它接受 onClick 的回调。 app-state 是一个全局可访问的原子。

我面临的问题是 login 里面的 go 块!永远不会被执行。我需要做些什么来刷新频道之类的吗?

我看到还有一个类似的未回答问题:Testing core.async code in ClojureScript。一个区别似乎是我在被测代码中没有显式通道。这是由 cljs-http post.

生成的

我认为您的问题是括号放错了。

(let [ch (chan)
      response {:status 200}]
    (go (>! ch response)
        ch))

let 的 return 值是 go 块的通道。这是一个什么都不包含的频道,因为:

  1. go 块正试图放入一个无缓冲的通道,需要一些其他操作来 "meet" 它并进行补充 take 以便它自己的执行继续进行。
  2. ch 在词法上对外界是隐藏的,因此不存在可以执行补语的操作。

如果以某种方式确实从中获取了某些东西(或者我们向 ch 添加了一个缓冲区,因此第一次放置成功),ch 将被放入 returned 通道。

(let [ch (chan)
      response {:status 200}]
    (go (>! ch response))
    ch)

let 的 return 值为 ch,没有额外的通道环绕它。 go-block 停在 ch 上,直到像你的测试这样的东西开始从它那里拿走。

但是,由于我们最终只是想构建一个带有常量的通道,go 本身似乎是最简单的解决方案:

(defn fake-login-success [& _]
  (go {:status 200})