mirror/oatpp
2
0
Fork 0
mirror of https://github.com/oatpp/oatpp.git synced 2025-02-05 17:09:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

HttpRequestExecutor. Set connection stream IOMode on request.

Browse Source
This commit is contained in:
lganzzzo 2020-01-08 00:02:01 +02:00
parent a166bac588
commit 69e8eb34fc
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/oatpp/web/client/HttpRequestExecutor.cpp
View File

@ -121,6 +121,9 @@ HttpRequestExecutor::executeOnce(const String& method,
throw RequestExecutionError(RequestExecutionError::ERROR_CODE_CANT_CONNECT,
"[oatpp::web::client::HttpRequestExecutor::executeOnce()]: Connection is null");
}
connection->setInputStreamIOMode(data::stream::IOMode::BLOCKING);
connection->setOutputStreamIOMode(data::stream::IOMode::BLOCKING);
auto request = oatpp::web::protocol::http::outgoing::Request::createShared(method, path, headers, body);
request->putHeaderIfNotExists(oatpp::web::protocol::http::Header::HOST, m_connectionProvider->getProperty("host"));
@ -216,6 +219,9 @@ HttpRequestExecutor::executeOnceAsync(const String& method,
"[oatpp::web::client::HttpRequestExecutor::executeOnceAsync::ExecutorCoroutine{act()}]: Connection is null");
}
m_connection->setInputStreamIOMode(data::stream::IOMode::ASYNCHRONOUS);
m_connection->setOutputStreamIOMode(data::stream::IOMode::ASYNCHRONOUS);
auto request = OutgoingRequest::createShared(m_method, m_path, m_headers, m_body);
request->putHeaderIfNotExists(Header::HOST, m_this->m_connectionProvider->getProperty("host"));
request->putHeaderIfNotExists(Header::CONNECTION, Header::Value::CONNECTION_KEEP_ALIVE);