mirror/oatpp
2
0
Fork 0
mirror of https://github.com/oatpp/oatpp.git synced 2025-01-06 16:24:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix to FIFOBuffer::flushToStreamAsync

Browse Source
This commit is contained in:
lganzzzo 2019-03-26 02:48:53 +02:00
parent 87dbdea99c
commit b1fcfc6641
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/oatpp/core/data/buffer/FIFOBuffer.cpp
View File

@ -310,6 +310,11 @@ oatpp::async::Action FIFOBuffer::flushToStreamAsync(oatpp::async::AbstractCorout
{} {}
Action act() override { Action act() override {
if(!m_fifo->m_canRead) {
return finish();
}
if(m_fifo->m_readPosition < m_fifo->m_writePosition) { if(m_fifo->m_readPosition < m_fifo->m_writePosition) {
m_data1 = &m_fifo->m_buffer[m_fifo->m_readPosition]; m_data1 = &m_fifo->m_buffer[m_fifo->m_readPosition];

2
src/oatpp/web/protocol/http/outgoing/Response.cpp
View File

@ -116,7 +116,7 @@ oatpp::async::Action Response::sendAsync(oatpp::async::AbstractCoroutine* parent
, m_buffer(oatpp::data::stream::ChunkedBuffer::createShared()) , m_buffer(oatpp::data::stream::ChunkedBuffer::createShared())
{} {}
Action act() { Action act() override {
if(m_response->m_body){ if(m_response->m_body){
m_response->m_body->declareHeaders(m_response->m_headers); m_response->m_body->declareHeaders(m_response->m_headers);