SimpleStatusHandler.h

Go to the documentation of this file.

#pragma once
 
#include <mutex>
#include <vector>
 
#include <armarx/view_selection/client/services/StatusHandlerInterface.h>
 
namespace armarx::view_selection::client
{
 
    /**
     * @brief Dispatches gaze target lifecycle updates to registered callbacks.
     *
     * Base of both delivery modes (MemorySubscriber, MemoryPolling), so instrumentation and
     * dispatch exist once regardless of how the updates were obtained.
     */
    class SimpleStatusHandler : virtual public StatusHandlerInterface
    {
    public:
        void onRequested(const Callback& callback) override;
        void onScheduled(const Callback& callback) override;
        void onReached(const Callback& callback) override;
        void onPreempted(const Callback& callback) override;
        void onReleased(const Callback& callback) override;
        void onAborted(const Callback& callback) override;
        void onAny(const Callback& callback) override;
 
        /// Logs the update and hands it to the matching callbacks.
        void handleStatus(const gaze_targets::GazeTargetStatus& status);
 
    private:
        std::mutex callbackMutex;
 
        struct
        {
            std::vector<Callback> requested;
            std::vector<Callback> scheduled;
            std::vector<Callback> reached;
            std::vector<Callback> preempted;
            std::vector<Callback> released;
            std::vector<Callback> aborted;
            std::vector<Callback> any;
        } subscriptions;
    };
 
} // namespace armarx::view_selection::client