Bug fix: using XREAD command instead of XRANGE (#82)

tcieslar · tomaszcieslar-studiodr · web-flow · commit a404338343fa · 2022-07-13T00:45:48.000+01:00
Co-authored-by: Tomasz Cieślar &lt;tomasz.cieslar@studiodr.pl&gt;
diff --git a/src/RedisClient/Command/Traits/Version5x0/StreamsCommandsTrait.php b/src/RedisClient/Command/Traits/Version5x0/StreamsCommandsTrait.php
@@ -282,9 +282,10 @@ public function xread($keys, $ids, $count = null, $block = null) {
         if (isset($block)) {
             $params[] = ['BLOCK', $block];
         }
+        $params[] = 'STREAMS';
         $params[] = $keys;
         $params[] = (array)$ids;
-        return $this->returnCommand(['XRANGE'], $keys, $params);
+        return $this->returnCommand(['XREAD'], $keys, $params);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -282,9 +282,10 @@ public function xread($keys, $ids, $count = null, $block = null) {`
`282`	`282`	`if (isset($block)) {`
`283`	`283`	`$params[] = ['BLOCK', $block];`
`284`	`284`	`}`
	`285`	`+ $params[] = 'STREAMS';`
`285`	`286`	`$params[] = $keys;`
`286`	`287`	`$params[] = (array)$ids;`
`287`		`- return $this->returnCommand(['XRANGE'], $keys, $params);`
	`288`	`+ return $this->returnCommand(['XREAD'], $keys, $params);`
`288`	`289`	`}`
`289`	`290`
`290`	`291`	`/**`