@@ -29,7 +29,7 @@ TMessageHolder<TMessage> TKv::Read(TMessageHolder<TCommandRequest> message, uint
2929 if (readKv->KeySize == 0 ) {
3030 std::string data;
3131 for (auto & [k, v] : H) {
32- data += k + " = " + v + " , " ;
32+ data += k + " = " + v + " \n " ;
3333 }
3434 auto res = NewHoldedMessage<TCommandResponse>(sizeof (TCommandResponse) + data.size ());
3535 memcpy (res->Data , data.data (), data.size ());
@@ -89,6 +89,7 @@ NNet::TFuture<void> Client(TPoller& poller, TSocket socket, uint32_t flags) {
8989 const char * sep = " \t\r\n " ;
9090
9191 try {
92+ std::cout << " > " << std::flush;
9293 while ((line = co_await lineReader.Read ())) {
9394 std::string strLine;
9495 strLine += std::string_view (line.Part1 .data (), line.Part1 .size ());
@@ -138,8 +139,11 @@ NNet::TFuture<void> Client(TPoller& poller, TSocket socket, uint32_t flags) {
138139 auto res = reply.template Cast <TCommandResponse>();
139140 auto len = res->Len - sizeof (TCommandResponse);
140141 std::string_view data (res->Data , len);
141- std::cout << " Ok, commitIndex: " << res->Index << " "
142- << data << " \n " ;
142+ std::cout << " Ok, commitIndex: " << res->Index << " \n " ;
143+ if (!data.empty ()) {
144+ std::cout << data << " \n " ;
145+ }
146+ std::cout << " > " << std::flush;
143147 }
144148 } catch (const std::exception& ex) {
145149 std::cout << " Exception: " << ex.what () << " \n " ;
0 commit comments