window_frame_tick()

MAYAFLUX_API std::shared_ptr< Vruta::BroadcastSource< WindowFrame > > MayaFlux::Kriya::window_frame_tick

(

const std::shared_ptr< Core::Window > &

window

)

Create a BroadcastSource<bool> ticking once per captured window frame.

Registers a frame observer with DisplayService for the given window. The window must have capture enabled and the capture state must have been initialized (either via WindowAccessProcessor or set_capture_enabled before the first rendered frame).

Returns nullptr if the DisplayService is unavailable, the window is null, or capture state is not yet active for the window.

The observer callback is non-blocking. Signal delivery is safe across thread boundaries; the BroadcastSource handles the coroutine resume path.

auto src = Kriya::window_frame_tick(window);
get_event_manager()->add_event(std::make_shared<Vruta::Event>(
    Kriya::on_signal(src, [](const Kriya::WindowFrame& frame) {
        // frame.data, frame.width, frame.height, frame.format
    })));

Definition at line 39 of file BroadcastEvents.cpp.

{
    auto* svc = Registry::BackendRegistry::instance()
                    .get_service<Registry::Service::DisplayService>();
 
    if (!svc || !window)
        return nullptr;
 
    struct State {
        Vruta::BroadcastSource<WindowFrame> source;
        Registry::Service::DisplayService* svc { nullptr };
        std::shared_ptr<Core::Window> window;
        uint32_t observer_id { 0 };
 
        ~State()
        {
            if (svc && observer_id) {
                svc->unregister_frame_observer(
                    std::static_pointer_cast<void>(window), observer_id);
            }
        }
    };
 
    auto state = std::make_shared<State>();
    state->svc = svc;
    state->window = window;
 
    state->observer_id = svc->register_frame_observer(
        std::static_pointer_cast<void>(window),
 
        [weak = std::weak_ptr<State>(state)](
            const std::shared_ptr<std::vector<uint8_t>>& buf,
            uint32_t w, uint32_t h, uint32_t fmt) {
            if (!buf) {
                return;
            }
 
            if (auto s = weak.lock())
                s->source.signal({ .data = buf, .width = w, .height = h, .format = fmt });
        });
 
    if (!state->observer_id)
        return nullptr;
 
    return { state, &state->source };
}

References MayaFlux::Registry::BackendRegistry::get_service(), h, MayaFlux::Registry::BackendRegistry::instance(), and MayaFlux::Registry::Service::DisplayService::unregister_frame_observer.

Here is the call graph for this function: