          :response
          [200 {"content-length" "5" "connection" "close"} "Hello"]))))
 
-  (let [upstream
+  (let [downstream
         (client/request
          ["Localhost" 4040]
          [{:path-info       "/"
            :request-method  "POST"
            "content-length" "5"
            "expect"         "100-continue"} :chunked]
-         (fn [upstream evt val]
+         (fn [downstream evt val]
            (enqueue ch2 [evt val])))]
 
     (is (next-msgs-for

     "transfer-encoding" "chunked"
     "connection"        "close"}
    :chunked]
   (fn [upstream-fn evt val]
     (enqueue ch2 [evt val])
     (when (= :connected evt)
       (upstream-fn :body "HELLO")
       (upstream-fn :body "WORLD")
       (upstream-fn :done nil))))

  (is (next-msgs-for
       ch2

   ["localhost" 4040]
   [{:path-info "/"
     :request-method "GET"}]
   (fn [downstream evt val]
     (enqueue ch2 [evt val])
     (downstream :abort nil)))

  (is (next-msgs-for
       ch2
