cpprestsdk: обработка фрагментированного ответа

Как мне обрабатывать фрагментированный ответ с помощью cpprestsdk? Как запросить следующий блок? Есть ли там вообще необходимый функционал?

Вот как мы выполняем http-запросы:

web::http::http_request request(web::http::methods::GET);
request.headers().add(LR"(User-Agent)", LR"(ExchangeServicesClient/15.00.0847.030)");
request.headers().add(LR"(Accept)", LR"(text/xml)");
request.set_body(L"request body", L"text/xml");

web::http::client::http_client_config clientConfig;
clientConfig.set_credentials(web::credentials(L"username", L"pass"));
clientConfig.set_validate_certificates(true);

web::http::client::http_client client(L"serviceurl", clientConfig);

auto bodyTask = client.request(request)
    .then([](web::http::http_response response) {
        auto str = response.extract_string().get();
        return str;
});

auto body = bodyTask.get();

Если я наивно пытаюсь выполнить другой запрос сразу после этого, я получаю сообщение об ошибке:

WinHttpSendRequest: 5023: группа или ресурс не находятся в правильном состоянии для выполнения запрошенной операции.


c++ chunked-encoding cpprest-sdk casablanca
person Dmitry Katkevich    schedule 21.03.2017    source источник
comment
похоже, они создали тест для такой функциональности: github.com/Microsoft/cpprestsdk/blob/master/Release/tests/ вам, возможно, придется проделать некоторую работу, чтобы направить результирующий поток в нужное место назначения.   -  person Sam Hatchett    schedule 07.04.2017

Ответы (1)


arrow_upward
1
arrow_downward

Чтобы прочитать полученные данные кусками, нужно получить входной поток из ответа сервера.

concurrency::streams::istream bodyStream = response.body();

затем непрерывно читайте из этого потока, пока не будет найден данный символ или не будет прочитано количество указанных байтов

pplx::task<void> repeat(Concurrency::streams::istream bodyStream)
{
Concurrency::streams::container_buffer<std::string> buffer;

return pplx::create_task([=] {
    auto t = bodyStream.read_to_delim(buffer, '\n').get();
    std::cout << buffer.collection() << std::endl;
    return t;
}).then([=](int /*bytesRead*/) {
    if (bodyStream.is_eof()) {
        return pplx::create_task([]{});
    }
    return repeat(bodyStream);
});
}

Вот полный пример: https://github.com/cristeab/oanda_stream

person Cristea Bogdan    schedule 14.08.2019