Fix heartbeat

calcinai · Dec 1, 2015 · 3aae0fd · 3aae0fd
1 parent 4d56281
commit 3aae0fd
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/src/Protocol/AbstractProtocol.php b/src/Protocol/AbstractProtocol.php
@@ -59,14 +59,15 @@ public function onHeartbeat(){
             $this->heartbeat_timer->cancel();
         }
 
-        //Set a new timeout (1 sec seems reasonable)
-        $this->heartbeat_timer = $this->client->getLoop()->addTimer(2, function(){
-            $this->stream->close();
-            throw new ConnectionLostException();
-        });
-
         $this->client->getLoop()->addTimer($this->client->getHeartbeatInterval(), function(){
+            //Set a new timeout (1 sec seems reasonable)
+            $this->heartbeat_timer = $this->client->getLoop()->addTimer(2, function(){
+                $this->stream->close();
+                throw new ConnectionLostException();
+            });
+
             $this->sendHeartbeat();
+
         });
     }