Feedback: update byte-streams require in example

Author: skynet-gh

examples/src/aleph/examples/http.clj

@@ -7,7 +7,7 @@
     [compojure.route :as route]
     [compojure.response :refer [Renderable]]
     [aleph.http :as http]
-    [byte-streams :as bs]
+    [clj-commons.byte-streams :as bs]
     [manifold.stream :as s]
     [manifold.deferred :as d]
     [clojure.core.async :as a]

examples/src/aleph/examples/udp.clj

@@ -1,10 +1,9 @@
 (ns aleph.examples.udp
   (:require
-    [manifold.deferred :as d]
     [manifold.stream :as s]
     [aleph.udp :as udp]
     [clojure.string :as str]
-    [byte-streams :as bs]))
+    [clj-commons.byte-streams :as bs]))
 
 ;; Full documentation for the `aleph.udp` namespace can be found [here](http://aleph.io/codox/aleph/aleph.udp.html).
 

examples/src/aleph/examples/websocket.clj

@@ -4,11 +4,9 @@
     [ring.middleware.params :as params]
     [compojure.route :as route]
     [aleph.http :as http]
-    [byte-streams :as bs]
     [manifold.stream :as s]
     [manifold.deferred :as d]
-    [manifold.bus :as bus]
-    [clojure.core.async :as a]))
+    [manifold.bus :as bus]))
 
 (def non-websocket-request
   {:status 400
@@ -111,8 +109,8 @@
 
 ;; Here we create two clients, and have them speak to each other
 (let [conn1 @(http/websocket-client "ws://localhost:10000/chat")
-      conn2 @(http/websocket-client "ws://localhost:10000/chat")
-      ]
+      conn2 @(http/websocket-client "ws://localhost:10000/chat")]
+      
 
   ;; sign our two users in
   (s/put-all! conn1 ["shoes and ships" "Alice"])
@@ -126,7 +124,7 @@
   (s/put! conn2 "hi!")
 
   @(s/take! conn1)   ;=> "Bob: hi!"
-  @(s/take! conn2)   ;=> "Bob: hi!"
-  )
+  @(s/take! conn2))   ;=> "Bob: hi!"
+  
 
 (.close s)