refactor: Refactor consumeResults

exaby73 · transistive · commit 61de1a84d7ec · 2024-10-09T12:28:03.000+05:30
diff --git a/src/Bolt/BoltConnection.php b/src/Bolt/BoltConnection.php
@@ -170,8 +170,7 @@ public function setTimeout(float $timeout): void
     public function consumeResults(): void
     {
         $this->logger?->log(LogLevel::DEBUG, 'Consuming results');
-        if ($this->protocol()->serverState !== ServerState::STREAMING && $this->protocol(
-        )->serverState !== ServerState::TX_STREAMING) {
+        if (!$this->isStreaming()) {
             $this->subscribedResults = [];
 
             return;

Original file line number	Diff line number	Diff line change
`@@ -170,8 +170,7 @@ public function setTimeout(float $timeout): void`
`170`	`170`	`public function consumeResults(): void`
`171`	`171`	`{`
`172`	`172`	`$this->logger?->log(LogLevel::DEBUG, 'Consuming results');`
`173`		`- if ($this->protocol()->serverState !== ServerState::STREAMING && $this->protocol(`
`174`		`- )->serverState !== ServerState::TX_STREAMING) {`
	`173`	`+ if (!$this->isStreaming()) {`
`175`	`174`	`$this->subscribedResults = [];`
`176`	`175`
`177`	`176`	`return;`