     (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

    (d/let-flow
     [handshake (s/take! s)]
     (-> ((condp = (:type handshake)
            :peering-handshake connect-peer-socket
            :table-tennis connect-table-tennis-socket
            :client-handshake connect-client-socket
            (fn [&_]
              (warn "Invalid handshake: " (:type handshake))
              (s/close! s)))

           (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)))
