start()

void MayaFlux::Yantra::Vision::VisionWorkflow::start ( const std::shared_ptr< Kakshya::VideoStreamContainer > &  source, const std::shared_ptr< Buffers::TextureBuffer > &  frames, const LiveConfig &  live, const std::shared_ptr< VisionMatrix > &  matrix, const std::string &  name, std::function< void(const VisionIO &)>  consumer, std::function< bool()>  stop_when = {}  )

private

Subscribe consumer and start the producer named name, which stops the run at source's end, or once stop_when reports true when it is given.

Definition at line 544 of file VisionWorkflow.cpp.

{
    auto results = std::make_shared<Vruta::BroadcastSource<VisionIO>>();
    auto event = Kriya::subscribe(*m_event_manager.lock(), results, std::move(consumer));
    keep(name, event);
 
    auto ended = stop_at_end(source, m_scheduler, m_event_manager, event, name);
    if (stop_when) {
        ended = [at_end = std::move(ended), stop_when = std::move(stop_when),
                    scheduler = m_scheduler, events = m_event_manager, weak_consumer = std::weak_ptr(event), name]() {
            if (at_end())
                return true;
            if (!stop_when())
                return false;
            stop_run(scheduler, events, weak_consumer, name);
            return true;
        };
    }
 
    start_producer(*m_scheduler.lock(), results, source, frames, live.apply_to, matrix, live.interval_seconds,
        ended, name);
}

References MayaFlux::Yantra::Vision::LiveConfig::apply_to, MayaFlux::Yantra::Vision::LiveConfig::interval_seconds, name, and MayaFlux::Kriya::subscribe().

Referenced by process_to_buffer(), process_to_live_container(), and process_to_stream().

Here is the call graph for this function:

Here is the caller graph for this function: