Method flush

valdi/src/valdi/runtime/Context/ViewNodesVisibilityObserver.cpp:21–89

ViewNodesVisibilityObserver::~ViewNodesVisibilityObserver() = default;

void ViewNodesVisibilityObserver::flush(const Ref<Context>& context) {
    if (_isFlushing || (_visibilityUpdates.empty() && _viewportUpdates.empty()) || _callback == nullptr) {
        return;
    }

    auto eventTime = _lastUpdateTime;
    _lastUpdateTime = TimePoint();

    size_t visibleIdsSize = 0;
    size_t invisibleIdsSize = 0;

    for (const auto& it : _visibilityUpdates) {
        if (it.second) {
            visibleIdsSize++;
        } else {
            invisibleIdsSize++;
        }
    }

    auto visibleIds = ValueArray::make(visibleIdsSize);
    auto invisibleIds = ValueArray::make(invisibleIdsSize);
    size_t visibleIdsIndex = 0;
    size_t invisibleIdsIndex = 0;

    for (const auto& it : _visibilityUpdates) {
        if (it.second) {
            (*visibleIds)[visibleIdsIndex++] = Value(it.first);
        } else {
            (*invisibleIds)[invisibleIdsIndex++] = Value(it.first);
        }
    }

    auto viewportUpdates = ValueArray::make(_viewportUpdates.size() * 5);

    size_t index = 0;
    for (const auto& it : _viewportUpdates) {
        auto frame = it.second;
        viewportUpdates->emplace(index++, Value(it.first));
        viewportUpdates->emplace(index++, Value(frame.x));
        viewportUpdates->emplace(index++, Value(frame.y));
        viewportUpdates->emplace(index++, Value(frame.width));
        viewportUpdates->emplace(index++, Value(frame.height));
    }

    _visibilityUpdates.clear();
    _viewportUpdates.clear();
    _isFlushing = true;

    auto updateId = context->enqueueUpdate();

    auto self = strongRef(this);
    auto callback = makeShared<ValueFunctionWithCallable>(
        [self, context, updateId](const ValueFunctionCallContext& /*callContext*/) -> Value {
            DispatchFunction dispatchFn = [self, context, updateId]() {
                self->onFlushAcknowledged(context);
                context->markUpdateCompleted(updateId);
            };
            if (self->_mainThreadManager != nullptr) {