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

    (is (no-msgs-for ch1))
    (is (no-msgs-for ch2))

    (upstream :body "Hello")
    (upstream :done nil)

    (is (next-msgs-for
         ch1

         :response
         [200 {"content-length" "5" "connection" "close"} "Hello"]))))

  (let [downstream
        (client/request
         ["Localhost" 4040]
         [{:path-info       "/"
           :request-method  "POST"
           "content-length" "5"
           "expect"         "100-continue"} :chunked]
         (fn [downstream evt val]
           (enqueue ch2 [evt val])))]

    (is (next-msgs-for
