write() [4/16]

void MayaFlux::Portal::Forma::Bridge::write	(	const ElementRef &	ref,
		std::function< void(std::span< const float >)>	sink
	)

Route element bulk value to a caller-supplied sink each frame.

When the element's MappedState<T> has a bulk_reader (T is vector<float>, vector<double> or a glm vector), the full value is forwarded as a span. For scalar T the sink receives a single-element span of the scalar value.

Intended for consumers that operate on coefficient arrays or other N-element state: FIR/IIR coefficient vectors, Random node bounds, any function accepting a contiguous float range.

Parameters

ref	Owning Layer and element id.
sink	Callable invoked each frame with the current value span.

Definition at line 310 of file Bridge.cpp.

{
    auto* rec = find_record(ref);
    if (!rec) {
        MF_ERROR(Journal::Component::Portal, Journal::Context::Init,
            "Bridge::write: unknown element id {}", ref.second);
        return;
    }
 
    auto name = make_task_name(ref.second, "bulk_sink");
    rec->outbound_tasks.push_back(name);
 
    auto bulk = rec->bulk_reader;
    auto reader = rec->reader;
 
    if (bulk) {
        auto routine = [](Vruta::TaskScheduler&,
                           std::function<std::vector<float>()> b,
                           std::function<void(std::span<const float>)> s)
            -> Vruta::GraphicsRoutine {
            auto& p = co_await Kriya::GetGraphicsPromise {};
            while (!p.should_terminate) {
                const auto v = b();
                s(v);
                co_await Kriya::FrameDelay { .frames_to_wait = 1 };
            }
        };
        m_scheduler.add_task(
            std::make_shared<Vruta::GraphicsRoutine>(
                routine(m_scheduler, std::move(bulk), std::move(sink))),
            name, false);
    } else {
        auto routine = [](Vruta::TaskScheduler&,
                           std::function<float()> r,
                           std::function<void(std::span<const float>)> s)
            -> Vruta::GraphicsRoutine {
            auto& p = co_await Kriya::GetGraphicsPromise {};
            float val {};
            while (!p.should_terminate) {
                val = r();
                s(std::span<const float> { &val, 1 });
                co_await Kriya::FrameDelay { .frames_to_wait = 1 };
            }
        };
        m_scheduler.add_task(
            std::make_shared<Vruta::GraphicsRoutine>(
                routine(m_scheduler, std::move(reader), std::move(sink))),
            name, false);
    }
}

References MayaFlux::Vruta::TaskScheduler::add_task(), b, find_record(), MayaFlux::Kriya::FrameDelay::frames_to_wait, MayaFlux::Journal::Init, m_scheduler, make_task_name(), MF_ERROR, name, and MayaFlux::Journal::Portal.

Here is the call graph for this function: