Method finishedWriting

Libraries/AsyncStreams/AsyncStreams.cpp:769–819

}

void AsyncWritableStream::finishedWriting(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)>&& callback,
                                          Result res)
{
    SC_ASYNC_STREAMS_ASSERT_RELEASE(state == State::Writing or state == State::Ending);

    if (not res)
    {
        eventError.emit(res);
    }

    bool    emitDrain = false;
    Request request;
    if (writeQueue.popFront(request))
    {
        tryAsync(asyncWrite(request.bufferID, request.cb));
        buffers->unrefBuffer(request.bufferID); // 2c. refbuffer in AsyncWritable::write
    }
    else
    {
        // Queue is empty
        if (state == State::Ending)
        {
            if (canEndWritable())
            {
                state = State::Ended;
            }
        }
        else
        {
            state     = State::Stopped;
            emitDrain = true;
        }
    }
    if (callback.isValid())
    {
        callback(bufferID);
    }

    if (state == State::Ended)
    {
        eventFinish.emit();
        if (autoDestroy)
        {
            destroy();
        }
    }
    else if (emitDrain)
    {
        eventDrain.emit();
    }
}

void AsyncWritableStream::end()
{