core.async pub/sub ведет себя странно в Om (clojurescript)

Почему счетчик в дочернем компоненте обновляется нормально, когда я комментирую

(om/update-state! owner :clicked not) 

а не когда я раскомментирую его в родительском компоненте в коде ниже? Счетчик обновляется нажатием кнопки.

То, что я пытаюсь реализовать, — это механизм публикации/подписки, чтобы компоненты могли обмениваться сообщениями несвязанным образом.

Вы можете воспроизвести его, создав новый проект с помощью:

lein new mies-om om-channel-test

Затем замените core.cljs приведенным ниже кодом и запустите

lein cljsbuild auto

Посетите страницу index.html в современном браузере (например, последней версии Chrome).

Код:

(ns om-channel-test.core
  (:require-macros [cljs.core.async.macros :refer (go)])
  (:require [om.core :as om :include-macros true]
            [om.dom :as dom :include-macros true]
            [cljs.core.async :refer [chan pub <! sub >! timeout put!]]))

(enable-console-print!)

(def app-state (atom {:text "Hello world!"}))

(def event-ch (chan))

(def event-pub
  (pub event-ch #(:topic %)))

(defn child [cursor owner]
  (reify
    om/IInitState
    (init-state [_]
      {:counter 0})
    om/IWillMount
    (will-mount [_]
      (go (loop [] (<! (om/get-state owner :subscriber))
                (println "message received")
                (om/update-state! owner :counter inc)
                (recur))))
    om/IRender
    (render [_]
      (println "rendering child")
      (dom/p nil (om/get-state owner :counter)))
    om/IWillUnmount
    (will-unmount [_]
      (println "unmount"))))

(defn parent [cursor owner]
  (om/component
   (println "rendering parent")
   (dom/div nil
            (dom/button #js {:onClick
                             #(do
                                #_(om/update-state! owner :clicked not)
                                (go (>! event-ch {:topic :wizard
                                                  :message "hello"})))}
                        "Click")
            (om/build child
                      cursor
                      {:init-state
                       {:subscriber
                        ((om/get-shared owner :create-subscriber) :wizard)}}))))

(om/root
 parent
 app-state
 {:target (. js/document (getElementById "app"))
  :shared {:create-subscriber (fn [topic]
                                (sub event-pub
                                     topic (chan)))
           :event-ch event-ch}})