Method afterFinalize

Libraries/AsyncStreams/AsyncStreams.cpp:986–1005

    }
}

void AsyncTransformStream::afterFinalize(Span<char> outputAfter, bool streamEnded)
{
    const size_t consumedOutput = outputData.sizeInBytes() - outputAfter.sizeInBytes();
    if (consumedOutput > 0)
    {
        // Ignore whatever push returns because later on the stream is either finalizing or pausing either way
        (void)AsyncReadableStream::push(outputBufferID, consumedOutput);
    }
    AsyncReadableStream::getBuffersPool().unrefBuffer(outputBufferID);
    if (streamEnded)
    {
        AsyncReadableStream::pushEnd();
        state = State::Finalized; // --> Transition to ENDED (all data written)
    }
    else
    {
        state = State::Paused;
        tryFinalize();
    }
}

void AsyncTransformStream::tryFinalize()