write_aggregate()

void MayaFlux::Portal::Forma::Bridge::write_aggregate ( Layer &  layer, std::vector< std::function< float()> >  readers, std::function< void(std::span< const float >)>  sink  )

private

Definition at line 473 of file Bridge.cpp.

{
    auto name = make_layer_task_name("bulk_sink");
    m_layer_tasks[layer.weak_from_this()].push_back(name);
 
    auto routine = [](Vruta::TaskScheduler&,
                       std::vector<std::function<float()>> sources,
                       std::function<void(std::span<const float>)> target)
        -> Vruta::GraphicsRoutine {
        auto& p = co_await Kriya::GetGraphicsPromise {};
        std::vector<float> values(sources.size());
        while (!p.should_terminate) {
            for (size_t i = 0; i < sources.size(); ++i)
                values[i] = sources[i]();
            target(values);
            co_await Kriya::FrameDelay { .frames_to_wait = 1 };
        }
    };
 
    m_scheduler.add_task(
        std::make_shared<Vruta::GraphicsRoutine>(
            routine(m_scheduler, std::move(readers), std::move(sink))),
        name, false);
}

References MayaFlux::Vruta::TaskScheduler::add_task(), MayaFlux::Kriya::FrameDelay::frames_to_wait, m_layer_tasks, m_scheduler, make_layer_task_name(), name, and values.

Referenced by write().

Here is the call graph for this function:

Here is the caller graph for this function: