Method executeRead

Libraries/AsyncStreams/AsyncStreams.cpp:565–601

        }
        break;
    }
    case State::Destroying:
    case State::Errored: break;
    }
}

Result AsyncReadableStream::finishedDestroyingReadable()
{
    if (state != State::Destroying)
        return Result::Error(AsyncStreamsResultCategory, AsyncStreamsError::InvalidReadableState);
    state     = State::Ended;
    destroyed = true;
    eventClose.emit();
    return Result(true);
}

void AsyncReadableStream::executeRead()
{
    state = State::Reading;
    if (not readQueue.isEmpty())
    {
        emitOnData();
    }
    while (state == State::Reading)
    {
        const Result res = asyncRead();
        if (res)
        {
            switch (state)
            {
            case State::SyncReadMore:
                // push + reactivate(true) have been called synchronously (inside this method)
                state = State::Reading;
                continue; // loop calling one more asyncRead
            case State::Reading:
                // push + reactivate(...) have not been called so this becomes an async call
                state = State::AsyncReading;
                break;
            case State::SyncPushing:
                state = State::Errored;