Fixed extractor empty queue handling

gplanchat · gplanchat · commit 7a14a83e95d9 · 2022-05-17T00:48:16.000+02:00
diff --git a/src/Extractor.php b/src/Extractor.php
@@ -68,6 +68,9 @@ public function extract(): iterable
     {
         while (true) {
             $message = $this->channel->get($this->topic);
+            if ($message === null) {
+                break;
+            }
             $this->channel->ack($message);
 
             yield new AcceptanceResultBucket(\json_decode($message->content, true));

Original file line number	Diff line number	Diff line change
`@@ -68,6 +68,9 @@ public function extract(): iterable`
`68`	`68`	`{`
`69`	`69`	`while (true) {`
`70`	`70`	`$message = $this->channel->get($this->topic);`
	`71`	`+ if ($message === null) {`
	`72`	`+ break;`
	`73`	`+ }`
`71`	`74`	`$this->channel->ack($message);`
`72`	`75`
`73`	`76`	`yield new AcceptanceResultBucket(\json_decode($message->content, true));`