From e76895ac0070936bcd322cdd2cc958b1421de439 Mon Sep 17 00:00:00 2001
From: Richard Newman <rnewman@twinql.com>
Date: Fri, 15 Jul 2016 12:36:46 -0700
Subject: [PATCH] Generalize test code for <?run to work in either environment.

Signed-off-by: Richard Newman <rnewman@twinql.com>
---
 src/datomish/exec_repl.cljc | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/src/datomish/exec_repl.cljc b/src/datomish/exec_repl.cljc
index 2a6ccdee..f572cb2c 100644
--- a/src/datomish/exec_repl.cljc
+++ b/src/datomish/exec_repl.cljc
@@ -17,11 +17,12 @@
            [[datomish.jdbc-sqlite]
             [datomish.pair-chan :refer [go-pair <?]]
             [datomish.util :refer [while-let]]
-            [clojure.core.async]])
+            [clojure.core.async :refer [<!]]])
      #?@(:cljs
            [[datomish.promise-sqlite]
             [datomish.pair-chan]
-            [datomish.util]])))
+            [datomish.util]
+            [cljs.core.async :refer [<!]]])))
 
 #?(:clj
 (defn pair-channel->lazy-seq
@@ -57,13 +58,13 @@
       "/tmp/foo.sqlite"
       '[:find ?page :in $ :where [?page :page/starred true ?t]]))
 
-#_(defn test-cljs []
+#_(defn test-run []
     (datomish.pair-chan/go-pair
       (let [d (datomish.pair-chan/<? (s/<sqlite-connection "/tmp/foo.sqlite"))]
-        (cljs.core.async/<! (ss/<ensure-current-version d))
+        (<! (ss/<ensure-current-version d))
         (let [chan (exec/<?run d
                                '[:find ?page :in $ :where [?page :page/starred true ?t]])]
           (println (datomish.pair-chan/<? chan))
           (println (datomish.pair-chan/<? chan))
-          (println (datomish.pair-chan/<? chan))))))
-
+          (println (datomish.pair-chan/<? chan))
+          (s/close d)))))