                                   results)))
                      (if (seq (filter #(= ch (first %)) results))
                        (do (aclose net ch) ; Handle a completed result-ch aput.
-                           (recur (inc ts)
-                                  listens
-                                  streams
+                           (recur (inc ts) listens streams
                                   (remove #(= (first %) ch) results)))
                        (println "UNKNOWN ch"
                                 listens :streams streams :results results)))))))))

                         server-recv-ch (achan-buf net end-point-buf-size)
                         close-server-recv-ch (achan net)]
                     ; TODO: Need to model running out of ports.
                     (recur (inc ts)
                            listens
                            (-> streams
                                (assoc client-send-ch {:send-ch client-send-ch
                                                       :recv-ch server-recv-ch

       (doseq [[result-ch msg] results]
         (aclose cleanup result-ch)))
  :done)

(defn add-result [results result-ch result]
  (if result-ch
    (conj results [result-ch :ok])
    results))

(defn make-net [actx request-listen-ch request-connect-ch & opts]
  (ago-loop net actx
