     (swap!
      state
      (fn [current-state]
-       (assoc current-state
-         :next-up-fn nil
-         :upstream   nil))))
+       (assoc current-state :next-up-fn nil :upstream nil))))
   (if (.last-write current-state)
     (.addListener (.last-write current-state)
                   netty/close-channel-future-listener)

   state
   (fn [current-state]
     (if (= waiting-for-response (.next-up-fn current-state))
       (assoc current-state
         :next-up-fn incoming-request)
       (assoc current-state
         :next-dn-fn nil
         :responded? true)))

  [state evt [_ hdrs body :as val] current-state]
  (when-not (= :response evt)
    (throw (Exception. "Um... responses start with the head?")))

  (let [write (.write (.ch current-state) (resp->netty-resp val))]
    (swap!
     state
