Skip to content
This repository was archived by the owner on Mar 5, 2023. It is now read-only.

Commit eb0997b

Browse files
committed
much harsher heartbeat handling
1 parent 1e36e6c commit eb0997b

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

wsapi.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -158,12 +158,11 @@ func (wh *wsHeartBeater) Run(interval time.Duration) {
158158
case <-ticker.C:
159159

160160
wh.Lock()
161-
timeSinceAck := time.Since(wh.lastAck)
162161
hasReceivedAck := wh.receivedAck
163162
wh.receivedAck = false
164163
wh.Unlock()
165164

166-
if !hasReceivedAck && timeSinceAck >= interval {
165+
if !hasReceivedAck {
167166
wh.onNoAck()
168167
} else {
169168
wh.SendBeat()

0 commit comments

Comments
 (0)