diff --git a/src/taoensso/sente.cljc b/src/taoensso/sente.cljc index 91549b2..87f185c 100644 --- a/src/taoensso/sente.cljc +++ b/src/taoensso/sente.cljc @@ -825,29 +825,32 @@ (recur udt-t1)))))) ;; Ajax handshake/poll - (let [updated-conn (upd-conn! :ajax uid client-id :any server-ch) - udt-open (:udt updated-conn) - send-handshake? (or (:init? updated-conn) (:handshake? params))] + (let [send-handshake? + (or + (:handshake? params) + (nil? (get-in @conns_ [:ajax uid client-id])))] (timbre/logf (if send-handshake? :info :trace) "[ajax/on-open] New server Ajax sch (poll/handshake) for %s: %s" (lid uid client-id) {:send-handshake? send-handshake?}) - (when (connect-uid! :ajax uid) - (receive-event-msg! [:chsk/uidport-open uid])) - (if send-handshake? ;; Client will immediately repoll (send-handshake! server-ch websocket?) - (when-let [ms lp-timeout-ms] - (go - (