Method resumeWriting

Libraries/AsyncStreams/AsyncStreams.cpp:712–748

}

void AsyncWritableStream::resumeWriting()
{
    switch (state)
    {
    case State::Stopped: {
        Request request;
        if (writeQueue.popFront(request))
        {
            state = State::Writing;
            tryAsync(asyncWrite(request.bufferID, request.cb));
            buffers->unrefBuffer(request.bufferID); // 2b. refBuffer above
        }
    }
    break;
    case State::Writing: {
        // This is fine, it has already been queued
    }
    break;
    case State::Ending:
        if (canEndWritable())
        {
            state = State::Ended;
            if (autoDestroy)
            {
                destroy();
            }
        }
        break;
    case State::Destroying: {
        // Invalid state, already destroyed or already destroying
        eventError.emit(Result::Error("AsyncWritableStream::resumeWriting - destroy already called"));
    }
    break;
    case State::Errored:
    case State::Ended: break;
    }
}

Result AsyncWritableStream::unshift(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)>&& cb)
{