    [{:path-info          "/"
      :request-method     "GET"
      "transfer-encoding" "chunked"} :chunked]
-   (fn [upstream evt val]
+   (fn [downstream evt val]
      (enqueue ch2 [evt val])
      (when (= :connected evt)
-       (upstream :body "Foo!")
-       (upstream :body "Bar!")
-       (upstream :done nil))))
+       (downstream :body "Foo!")
+       (downstream :body "Bar!")
+       (downstream :done nil))))
 
   (is (next-msgs-for
        ch1

(defcoretest issuing-immediate-abort
  [_ ch]
  :hello-world
  (let [upstream
        (client/request
         ["localhost" 4040]
         [{:path-info      "/"
           :request-method "POST"} nil]
         (fn [_ evt val]
           (enqueue ch [evt val])))]
    (upstream :abort nil))

  (is (not-receiving-messages))

         :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
