Method retryPendingWrites

Libraries/AsyncStreams/AsyncStreams.cpp:1399–1431

}

bool AsyncPipeline::retryPendingWrites()
{
    for (PendingWrite& pendingWrite : pendingWrites)
    {
        if (not pendingWrite.bufferID.isValid())
            continue;

        SC_ASYNC_STREAMS_ASSERT_RELEASE(pendingWrite.writable != nullptr);
        if (not pendingWrite.writable->canAcceptWrite())
        {
            continue;
        }

        Function<void(AsyncBufferView::ID)> func;
        func.template bind<AsyncPipeline, &AsyncPipeline::afterWrite>(*this);
        const Result res = pendingWrite.writable->write(pendingWrite.bufferID, func);
        if (res)
        {
            pendingWrite.readable = nullptr;
            pendingWrite.writable = nullptr;
            pendingWrite.bufferID = {};
        }
        else
        {
            source->getBuffersPool().unrefBuffer(pendingWrite.bufferID);
            pendingWrite.readable = nullptr;
            pendingWrite.writable = nullptr;
            pendingWrite.bufferID = {};
            eventError.emit(res);
        }
    }
    return not hasPendingWrites();
}

void AsyncPipeline::afterWrite(AsyncBufferView::ID bufferID)
{