Method push

Libraries/AsyncStreams/AsyncStreams.cpp:371–418

}

bool AsyncReadableStream::push(AsyncBufferView::ID bufferID, size_t newSize)
{
    if (newSize == 0)
    {
        emitError(Result::Error("AsyncReadableStream::push zero sized buffer is not allowed"));
        return false;
    }
    // Push buffer to the queue
    buffers->setNewBufferSize(bufferID, newSize);
    Request request;
    request.bufferID = bufferID;
    if (not readQueue.pushBack(request))
    {
        state = State::Errored;
        emitError(Result::Error("AsyncReadableStream::push dropping buffer"));
        return false;
    }
    buffers->refBuffer(bufferID); // 1a. unrefBuffer in emitOnData()

    switch (state)
    {
    case State::SyncPushing:
    case State::Reading: {
        emitOnData();
        state = State::SyncPushing;
    }
    break;
    case State::AsyncPushing:
    case State::AsyncReading: {
        emitOnData();
        if (state == State::AsyncReading)
        {
            state = State::AsyncPushing;
        }
    }
    break;
    case State::Pausing: {
        // Process buffers received while Pausing is being propagated upstream
        emitOnData();
    }
    break;
    default: {
        emitError(Result::Error("AsyncReadableStream::push - called in wrong state"));
    }
    break;
    }
    return state == State::AsyncPushing or state == State::SyncPushing;
}

Result AsyncReadableStream::unshift(AsyncBufferView::ID bufferID)
{