Fix virtual_::Pipe::Reader::WaitListListener

This commit is contained in:
lganzzzo 2019-04-28 02:18:15 +03:00
parent 90cf16181a
commit 744d8e03fa

View File

@ -64,7 +64,7 @@ public:
void onNewItem(oatpp::async::CoroutineWaitList& list) override {
std::lock_guard<std::mutex> lock(m_pipe->m_mutex);
if (m_pipe->m_fifo.availableToRead() > 0) {
if (m_pipe->m_fifo.availableToRead() > 0 || !m_pipe->m_open) {
list.notifyAllAndClear();
}
}