Method async_receive

implementation/endpoints/src/local_socket_uds_impl.cpp:82–89

}

void local_socket_uds_impl::async_receive(boost::asio::mutable_buffer _buffer, read_handler _r_handler) {
    std::unique_lock lock{socket_mtx_};
    if (socket_->is_open()) {
        socket_->async_receive(_buffer, std::move(_r_handler));
    } else {
        boost::asio::post(io_context_, [h = std::move(_r_handler)] { h(boost::asio::error::fault, 0); });
    }
}

void local_socket_uds_impl::async_send(std::vector<uint8_t> _data, write_handler _w_handle) {
    std::unique_lock lock{socket_mtx_};