#ifndef C251BA62_6D80_4033_86B6_61F184E6F250 #define C251BA62_6D80_4033_86B6_61F184E6F250 #include #include #include "textPacketHandler.hpp" using namespace std::string_literals; std::vector buffer; void bufHandler(const char *buf){ std::string line = buf; // Remove last char which is \n line = line.substr(0, line.size()-1); // When first char of buf has text (no tab), we got a new packet if(buf[0] != '\t'){ // Submit the just-read text-packet in a new thread if(buffer.size() != 0) { (void)std::async(std::launch::async, textPacketHandler, buffer); } buffer = {line}; } else buffer.push_back(line); // Append part-packet } #endif /* C251BA62_6D80_4033_86B6_61F184E6F250 */