spawn_inbound()

void MayaFlux::Portal::Forma::Bridge::spawn_inbound ( const ElementRef &  ref, std::function< float()>  source  )

private

Definition at line 66 of file Bridge.cpp.

{
    auto* rec = find_record(ref);
    if (!rec) {
        MF_ERROR(Journal::Component::Portal, Journal::Context::Init,
            "Bridge::bind: unknown element id {}", ref.second);
        return;
    }
 
    cancel_inbound(*rec);
 
    auto name = make_task_name(ref.second, "inbound");
    rec->inbound_task = name;
 
    auto writer = rec->writer;
 
    auto routine = [](Vruta::TaskScheduler&,
                       std::function<float()> src,
                       std::function<void(float)> write) -> Vruta::GraphicsRoutine {
        auto& p = co_await Kriya::GetGraphicsPromise {};
        while (!p.should_terminate) {
            write(src());
            co_await Kriya::FrameDelay { .frames_to_wait = 1 };
        }
    };
 
    m_scheduler.add_task(
        std::make_shared<Vruta::GraphicsRoutine>(
            routine(m_scheduler, std::move(source), std::move(writer))),
        name, false);
}

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

Referenced by bind(), and bind().

Here is the call graph for this function:

Here is the caller graph for this function: