Method afterProcess

Libraries/AsyncStreams/AsyncStreams.cpp:956–984

    }
}

void AsyncTransformStream::afterProcess(Span<const char> inputAfter, Span<char> outputAfter)
{
    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 (inputAfter.empty())
    {
        auto cb        = move(inputCallback);
        auto bufferID  = inputBufferID;
        inputCallback  = {};
        inputBufferID  = {};
        inputData      = {};
        outputBufferID = {};
        outputData     = {};
        state          = State::None;
        AsyncWritableStream::finishedWriting(bufferID, move(cb), Result(true));
    }
    else
    {
        inputData = inputAfter;

        state = State::Paused;
        tryAsync(asyncWrite(inputBufferID, inputCallback));
    }
}

void AsyncTransformStream::afterFinalize(Span<char> outputAfter, bool streamEnded)