fix the return

apache · Jul 17, 2023 · f493955 · f493955
1 parent 8876d60
commit f493955
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/commands/cmd_stream.cc b/src/commands/cmd_stream.cc
@@ -741,7 +741,8 @@ class CommandXRead : public Commander,
       std::vector<StreamEntry> result;
       auto s = stream_db.Range(streams_[i], options, &result);
       if (!s.ok() && !s.IsNotFound()) {
-        return {Status::RedisExecErr, s.ToString()};
+        conn_->Reply(redis::Error("ERR " + s.ToString()));
+        return;
       }
 
       if (result.size() > 0) {