gistfile1.clj

(ns example.test
  (:require [aleph.tcp :as tcp]
            [manifold.stream :as stream]))

(defn handler [s info]
  (println "START")
  (println @(stream/take! s))
  (println "STOP"))

(defn start-server
  [port]
  (tcp/start-server handler {:port port}))

(def server (start-server 5555))

(def c @(tcp/client {:port 5555 :host "localhost"}))
(stream/put! c "example")

;;Prints only the following
;;START