Fix test cases

apache · Jan 15, 2024 · 86963fc · 86963fc
1 parent 3df2070
commit 86963fc
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/commands/cmd_stream.cc b/src/commands/cmd_stream.cc
@@ -862,15 +862,15 @@ class CommandXRead : public Commander,
 
     if (block_ && results.empty()) {
       if (conn->IsInExec()) {
-        *output = conn_->NilArray();
+        *output = conn->NilArray();
         return Status::OK();  // No blocking in multi-exec
       }
 
       return BlockingRead(srv, conn, &stream_db);
     }
 
     if (!block_ && results.empty()) {
-      *output = conn_->NilArray();
+      *output = conn->NilArray();
       return Status::OK();
     }
 
@@ -976,10 +976,10 @@ class CommandXRead : public Commander,
       conn_->Reply(conn_->NilArray());
     }
 
-    SendReply(conn_, results);
+    SendReply(results);
   }
 
-  void SendReply(Connection *conn, const std::vector<StreamReadResult> &results) {
+  void SendReply(const std::vector<StreamReadResult> &results) {
     std::string output;
 
     output.append(redis::MultiLen(results.size()));
@@ -991,7 +991,7 @@ class CommandXRead : public Commander,
       for (const auto &entry : result.entries) {
         output.append(redis::MultiLen(2));
         output.append(redis::BulkString(entry.key));
-        output.append(conn->MultiBulkString(entry.values));
+        output.append(conn_->MultiBulkString(entry.values));
       }
     }