     (doseq [p pkts]
       (when-not (send-pkt @state p))
           ;; (warn (:id @state) " trying to reconnect to peer: " (:dst (first pkts)))
-          ;; (reconnect-to-peer state (:dst (first pkts)))
+      ;;(reconnect-to-peer state (:dst (first pkts)))
           )))
 
-(defn- handle-rx-pkt
+(defn- handle-rx-pkt!
   "appends the pkt and runs update"
   [state dt pkt]
   (swap! state

           (server/update-state dt (update s :rx-queue conj pkt))))
  true)

(defn- handle-timeout
  "timeout of dt seconds, just run the update"
  [state dt]
  (swap! state (fn [s] (server/update-state dt s)))

  (d/chain (tcp/client {:host host, :port port})
           #(wrap-duplex-stream protocol %)))

(defn- connect-peer-socket!
  "Connects the peer messages to the :rx-stream"
  [state socket handshake]
  (info (:id @state) " accepting peer connection from: " (:src handshake))
