Pass TTL to idle generator and handle false TTL

Author: stevebauman

src/Idle.php

@@ -54,7 +54,7 @@ public function await(callable $callback): void
     protected function listen(callable $callback, CarbonInterface $ttl): void
     {
         // Iterate over responses yielded by the idle generator.
-        foreach ($this->idle() as $response) {
+        foreach ($this->idle($ttl) as $response) {
             if (! $response instanceof UntaggedResponse) {
                 continue;
             }
@@ -67,6 +67,10 @@ protected function listen(callable $callback, CarbonInterface $ttl): void
                 $ttl = $this->getNextTimeout();
             }
 
+            if ($ttl === false) {
+                break;
+            }
+
             // If we've been idle too long, break out to restart the session.
             if (Carbon::now()->greaterThanOrEqualTo($ttl)) {
                 $this->restart();
@@ -143,9 +147,11 @@ protected function done(): void
     /**
      * Begin a new IDLE session as a generator.
      */
-    protected function idle(): Generator
+    protected function idle(CarbonInterface $ttl): Generator
     {
-        yield from $this->mailbox->connection()->idle($this->timeout);
+        yield from $this->mailbox->connection()->idle(
+            (int) Carbon::now()->diffInSeconds($ttl)
+        );
     }
 
     /**