pipes-examples.clj

(ns se.raek.pipes.examples
  (:use se.raek.pipes
        clojure.contrib.server-socket
        clojure.test))

(with-test
  (defn upper-responses [seq]
    (->> seq
         (filter #(.startsWith % "to-upper: "))
         (map #(.toUpperCase %))))
  
  (is (= ["TO-UPPER: FOO"]
           (upper-responses ["ignore this..."
                             "to-upper: foo"
                             "...and this"]))))

(with-test
  (defn lower-responses [seq]
    (->> seq
         (filter #(.startsWith % "to-lower: "))
         (map #(.toLowerCase %))))
  
  (is (= ["to-lower: foo"]
           (lower-responses ["ignore this..."
                             "to-lower: FOO"
                             "...and this"]))))

(defn handle-connection [is os]
  (let [in-seq (source-seq (line-source is))
        out-sink (line-sink os)
        upper-feeder (feed! out-sink (upper-responses in-seq))
        lower-feeder (feed! out-sink (lower-responses in-seq))]
    ((:wait upper-feeder))
    ((:wait lower-feeder))))

(def server (create-server 9001 #'handle-connection))