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

       :request-method     "POST"
       "transfer-encoding" "chunked"
       "connection"        "close"} :chunked]
     (fn [upstream-fn evt val]
       (enqueue ch2 [evt val])
       (when (= :connected evt)
         (bg-while @latch (upstream-fn :body "HAMMER TIME!")))
       (when (= :pause evt) (toggle! latch))
       (when (= :resume evt)
         (upstream-fn :done nil))))

    (is (next-msgs-for
         ch2

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

  (is (next-msgs-for
       ch2
