write() [9/12]

void MayaFlux::Portal::Forma::Bridge::write	(	uint32_t	id,
		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> or vector<double>), the full vector 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

id	Element id.
sink	Callable invoked each frame with the current value span.

Definition at line 277 of file Bridge.cpp.

{
    auto it = m_records.find(id);
    if (it == m_records.end()) {
        MF_ERROR(Journal::Component::Portal, Journal::Context::Init,
            "Bridge::write: unknown element id {}", id);
        return;
    }
 
    auto name = make_task_name(id, "bulk_sink");
    it->second.outbound_tasks.push_back(name);
 
    auto bulk = it->second.bulk_reader;
    auto reader = it->second.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, MayaFlux::Kriya::FrameDelay::frames_to_wait, MayaFlux::Journal::Init, m_records, m_scheduler, make_task_name(), MF_ERROR, and MayaFlux::Journal::Portal.

Here is the call graph for this function: