249{
250 try {
251 auto command_copy {std::make_shared<std::string>(lr_ipc_out_shared->command_.pop())};
252 if (*command_copy == kTerminate) [[unlikely]] { return; }
253 if (command_copy->back() != '\n') [[unlikely]] {
254 command_copy->push_back('\n');
255 }
256 asio::async_write(lr_ipc_out_shared->socket_, asio::buffer(*command_copy),
257 [command_copy, lr_ipc_out_shared](const asio::error_code& error, std::size_t) mutable {
258 if (!error) [[likely]] { SendOut(std::move(lr_ipc_out_shared)); }
259 else {
260 rsj::Log(fmt::format(FMT_STRING("LR_IPC_Out Write: {}."), error.message()));
261 }
262 });
263 }
264 catch (const std::exception& e) {
266 throw;
267 }
268}
void ExceptionResponse(gsl::czstring id, gsl::czstring fu, const std::exception &e) noexcept