factor out channels/pipelines to lamina

dakrone · Nov 3, 2010 · c30c943 · c30c943
1 parent 42cc8be
commit c30c943
Show file tree

Hide file tree

Showing 35 changed files with 30 additions and 1,640 deletions.
diff --git a/README.textile b/README.textile
@@ -43,7 +43,7 @@ Making a simple chat client is trivial.  In this, we assume that the first messa
 (defn chat-handler [ch handshake]
   (receive ch
     (fn [name]
-       (receive-all ch #(when % (enqueue broadcast-channel (str name ": " %))))
+	   (siphon (map* #(str name ": " %) ch) broadcast-channel)
        (siphon broadcast-channel ch))))
 
 (start-http-server chat-handler {:port 8080 :websocket true})

diff --git a/aleph-core/.gitignore b/aleph-core/.gitignore
diff --git a/aleph-core/README b/aleph-core/README
diff --git a/aleph-core/local-push b/aleph-core/local-push
diff --git a/aleph-core/project.clj b/aleph-core/project.clj
diff --git a/aleph-core/push b/aleph-core/push
diff --git a/aleph-core/src/aleph/core.clj b/aleph-core/src/aleph/core.clj