Method afterWrite

Libraries/AsyncStreams/AsyncStreams.cpp:1433–1467

}

void AsyncPipeline::afterWrite(AsyncBufferView::ID bufferID)
{
    // Decrement reference count of the buffer that was just written
    source->getBuffersPool().unrefBuffer(bufferID);

    const bool drainedPendingWrites = retryPendingWrites();
    if (not drainedPendingWrites)
    {
        return;
    }

    if (shouldEndWhenDrained)
    {
        if (source != nullptr and source->hasQueuedData())
        {
            source->resumeReading();
            return;
        }
        shouldEndWhenDrained = false;
        endPipes();
        return;
    }

    // Try resume in reverse
    for (size_t idx = 0; idx < MaxTransforms; ++idx)
    {
        AsyncDuplexStream* transform = transforms[MaxTransforms - 1 - idx];
        if (transform)
        {
            transform->resumeWriting();
            transform->resumeReading();
        }
    }
    source->resumeReading();
}

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