Merge branch 'master' of github.com:ztellman/lamina

src/lamina/cache.clj

@@ -18,7 +18,7 @@
 (definterface+ IChannelCache
   (get-or-create [cache id on-create]
     "Gets a channel keyed to `id`.  If `on-create` is non-nil and the entry must be created, 
-     it will be called with zero parameters.
+     it will be called with the new channel as a parameter.
 
      If the channel returned is closed, it will be implicitly removed from the cache.")
   (ids [cache]

src/lamina/core/named.clj

@@ -19,7 +19,7 @@
 
 (defn named-channel
   "Returns a permanent channel keyed to `id`.  If the channel doesn't already exist and `on-create` is non-nil, 
-   it will be invoked with zero parameters."
+   it will be invoked with the new channel as a parameter."
   [id on-create]
   (cache/get-or-create named-channels id on-create))
 

src/lamina/core/operators.clj

@@ -724,7 +724,7 @@
                        (sink #(println \"average for\" facet-value \"is\" %))))})"
   [{:keys [facet initializer on-clearance]}]
   (let [receiver (g/node identity)
-        watch-channel (atom (fn [_]))
+        watch-channel (atom (fn [_ _]))
         propagator (g/distributing-propagator facet
                      (fn [id]
                        (let [ch (channel* :description (pr-str id))]

src/lamina/executor.clj

@@ -26,10 +26,10 @@
    value or error."
   [& body]
   (let [explicit-name? (string? (first body))
-        name (if explicit-name? (first body) "task")
+        name (symbol (if explicit-name? (first body) "task"))
         body (if explicit-name? (rest body) body)]
     `((trace/instrumented-fn
-        task
+        ~name
         {:executor default-executor}
         []
         ~@body))))
@@ -39,7 +39,7 @@
    value or error.  Unlike `task`, thread-local bindings are preserved when evaluating the body."
   [& body]
   (let [explicit-name? (string? (first body))
-        name (if explicit-name? (first body) "bound-task")
+        name (symbol (if explicit-name? (first body) "bound-task"))
         body (if explicit-name? (rest body) body)]
     `((trace/instrumented-fn
         ~name