Method receive

src/ipc/asio_transport.cpp:108–128

}

std::size_t AsioTransport::receive(std::span<std::byte> dst) {
    bool done = false;
    asio::error_code op_ec;
    std::size_t n = 0;
    socket_.async_read_some(
        asio::buffer(dst.data(), dst.size()),
        [&op_ec, &n, &done](const asio::error_code& e, std::size_t got) {
            op_ec = e;
            n = got;
            done = true;
        });
    if (run_until(*ctx_, socket_, done, timeout_)) {
        throw_socket_timeout_error("read");
    }
    if (op_ec) {
        // EOF/error -> read_impl escalates the 0 to a timeout.
        disconnected_ = true;
        return 0;
    }
    return n;
}

bool AsioTransport::has_data() const {
    asio::error_code ec;