Merge pull request #126 from roman-huliak/patch-1

Call HB if communication is still active

Author: WyriHaximus

Diff for: src/Bunny/Client.php

@@ -189,7 +189,10 @@ public function run($maxSeconds = null)
             } else {
                 if (($frame = $this->reader->consumeFrame($this->readBuffer)) === null) {
                     $now = microtime(true);
-                    $nextStreamSelectTimeout = $nextHeartbeat = ($this->lastWrite ?: $now) + $this->options["heartbeat"];
+                    $nextStreamSelectTimeout = ($this->lastWrite ?: $now) + $this->options["heartbeat"];
+                    if (!isset($nextHeartbeat)) {
+                        $nextHeartbeat = $now + $this->options["heartbeat"];
+                    }
                     if ($stopTime !== null && $stopTime < $nextStreamSelectTimeout) {
                         $nextStreamSelectTimeout = $stopTime;
                     }
@@ -224,6 +227,7 @@ public function run($maxSeconds = null)
                     $now = microtime(true);
 
                     if ($now >= $nextHeartbeat) {
+                        $nextHeartbeat = $now + $this->options["heartbeat"];
                         $this->writer->appendFrame(new HeartbeatFrame(), $this->writeBuffer);
                         $this->flushWriteBuffer();