ci: fix consumer trait test helper

dirx · dirx · commit 3c00b54e7ddb · 2025-01-21T21:18:28.000+01:00
diff --git a/tests/ConsumeTrait.php b/tests/ConsumeTrait.php
@@ -22,15 +22,15 @@ protected function consumeMessages(
                 $this->fail(sprintf('Consume Kafka Message timeout %s ms exceeded', self::$MAX_CONSUME_TIMEOUT_MS));
             }
             $message = $consumeCallback();
-            if ($message->err === RD_KAFKA_RESP_ERR__TIMED_OUT) {
-                break;
-            }
             if ($message === null) {
                 if ($continueOnNull) {
                     continue;
                 }
                 break;
             }
+            if ($message->err === RD_KAFKA_RESP_ERR__TIMED_OUT) {
+                break;
+            }
             $messages[] = $message;
         } while (count($messages) < $numberOfMessages);
 

Original file line number	Diff line number	Diff line change
`@@ -22,15 +22,15 @@ protected function consumeMessages(`
`22`	`22`	`$this->fail(sprintf('Consume Kafka Message timeout %s ms exceeded', self::$MAX_CONSUME_TIMEOUT_MS));`
`23`	`23`	`}`
`24`	`24`	`$message = $consumeCallback();`
`25`		`- if ($message->err === RD_KAFKA_RESP_ERR__TIMED_OUT) {`
`26`		`- break;`
`27`		`- }`
`28`	`25`	`if ($message === null) {`
`29`	`26`	`if ($continueOnNull) {`
`30`	`27`	`continue;`
`31`	`28`	`}`
`32`	`29`	`break;`
`33`	`30`	`}`
	`31`	`+ if ($message->err === RD_KAFKA_RESP_ERR__TIMED_OUT) {`
	`32`	`+ break;`
	`33`	`+ }`
`34`	`34`	`$messages[] = $message;`
`35`	`35`	`} while (count($messages) < $numberOfMessages);`
`36`	`36`