Method resumeReading

Libraries/AsyncStreams/AsyncStreams.cpp:481–520

}

void AsyncReadableStream::resumeReading()
{
    switch (state)
    {
    case State::Pausing:
    case State::Paused: {
        executeRead(); // -> State::Reading
    }
    break;
    case State::Ended: {
        if (not readQueue.isEmpty())
        {
            emitOnData();
        }
        else
        {
            maybeDestroyEndedReadable();
        }
    }
    break;
    case State::CanRead: {
        executeRead(); // -> State::Reading
    }
    break;
    case State::AsyncReading: {
        Result res = asyncResumeReading();
        if (not res)
        {
            emitError(res);
        }
    }
    break;
    case State::Stopped:
    case State::Errored: {
        emitError(Result::Error("AsyncReadableStream::resume - called in wrong state"));
    }
    break;
    default: break; // Ignore resume requests while reading
    }
}

void AsyncReadableStream::destroy()
{