{

if (!async_pipe_.initialize(cfg))

return false;

using namespace std::placeholders;

async_pipe_.setCallback(std::bind(&AsyncChannel::onPipeAppend, this, _1, _2));

return true;

{

const char *start_ptr = static_cast<const char *>(data_ptr);

const char *end_ptr = start_ptr + data_size;

for (;;) {

auto zero_ptr = std::find(start_ptr, end_ptr, 0);

if (zero_ptr != end_ptr) {

string_buff_ += start_ptr;

start_ptr = zero_ptr + 1;

onLogBackEnd(string_buff_);

string_buff_.clear();

} else {

std::for_each(start_ptr, end_ptr,

[=] (char c) {

string_buff_.push_back(c);

}

);

break;

}

}