                      ; 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
-                                                       :close-recv-ch close-server-recv-ch
-                                                       :accept-addr accept-addr :accept-port accept-port
-                                                       :server-addr accept-addr :server-port to-port
-                                                       :client-addr from-addr :client-port from-port
-                                                       :side :client :msgs []})
-                                (assoc server-send-ch {:send-ch server-send-ch
-                                                       :recv-ch client-recv-ch
-                                                       :close-recv-ch close-client-recv-ch
-                                                       :accept-addr accept-addr :accept-port accept-port
-                                                       :server-addr accept-addr :server-port to-port
-                                                       :client-addr from-addr :client-port from-port
-                                                       :side :server :msgs []}))
+                                (assoc client-send-ch
+                                  {:send-ch client-send-ch
+                                   :recv-ch server-recv-ch
+                                   :close-recv-ch close-server-recv-ch
+                                   :accept-addr accept-addr :accept-port accept-port
+                                   :server-addr accept-addr :server-port to-port
+                                   :client-addr from-addr :client-port from-port
+                                   :side :client :msgs []})
+                                (assoc server-send-ch
+                                  {:send-ch server-send-ch
+                                   :recv-ch client-recv-ch
+                                   :close-recv-ch close-client-recv-ch
+                                   :accept-addr accept-addr :accept-port accept-port
+                                   :server-addr accept-addr :server-port to-port
+                                   :client-addr from-addr :client-port from-port
+                                   :side :server :msgs []}))
                             (-> results
-                                (conj [false result-ch [client-send-ch client-recv-ch
-                                                        close-client-recv-ch accept-addr to-port]])
-                                (conj [true accept-ch [server-send-ch server-recv-ch
-                                                       close-server-recv-ch from-addr from-port]]))))
+                                (conj [false result-ch
+                                       [client-send-ch client-recv-ch
+                                        close-client-recv-ch accept-addr to-port]])
+                                (conj [true accept-ch
+                                       [server-send-ch server-recv-ch
+                                        close-server-recv-ch from-addr from-port]]))))
                    (do (aclose net result-ch)
                        (recur (inc ts) listens streams results)))
                  (net-clean-up net listens streams results))
-               (some #(= ch %) send-chs) ; A participant put to a send-ch or closed a send-ch.
+               (some #(= ch %) send-chs) ; A peer put to a send-ch or closed a send-ch.
                (let [send-ch ch
                      stream (get streams send-ch)]
                  (if-let [[msg result-ch] v]

(ns cbfg.net
  (:require-macros [cbfg.act :refer [achan achan-buf act act-loop aclose aalts aput]]))

(defn net-clean-up [actx listens streams results]
  (act cleanup actx

                                  (dissoc listens addr-port)
                                  streams
                                  results)))
                     (if-let [[keep-open-bool result-ch result-msg] ; Or, was result-ch aput.
                              (first (filter #(= (second %) ch) results))]
                       (do (when (not keep-open-bool)
                             (aclose net ch))
