Function AddStreamEntriesToResponse

src/commands/cmd_stream.cc:54–61

}  // namespace

void AddStreamEntriesToResponse(std::string *output, const std::vector<StreamEntry> &entries) {
  output->append(redis::MultiLen(entries.size()));
  for (const auto &entry : entries) {
    output->append(redis::MultiLen(2));
    output->append(redis::BulkString(entry.key));
    output->append(redis::ArrayOfBulkStrings(entry.values));
  }
}

class CommandXAck : public Commander {
 public: