MemorySubscriber.h

Go to the documentation of this file.

#pragma once
 
 
#include <mutex>
#include <string>
#include <vector>
 
#include <RobotAPI/libraries/armem/client/Reader.h>
#include <RobotAPI/libraries/armem/client/util/SubscriptionHandle.h>
#include <RobotAPI/libraries/armem/core/MemoryID.h>
#include <RobotAPI/libraries/armem/core/forward_declarations.h>
#include <RobotAPI/libraries/armem/core/wm/memory_definitions.h>
 
#include <armarx/navigation/client/services/SimpleEventHandler.h>
 
namespace armarx::armem::client
{
    class MemoryNameSystem;
}
 
namespace armarx::navigation::client
{
 
    class MemorySubscriber : virtual public SimpleEventHandler
    {
 
    public:
        MemorySubscriber(const std::string& callerId, armem::client::MemoryNameSystem& mns);
 
        MemorySubscriber(const MemorySubscriber&) = delete;
        MemorySubscriber(MemorySubscriber&&) = delete;
        MemorySubscriber& operator=(const MemorySubscriber&) = delete;
        MemorySubscriber& operator=(MemorySubscriber&&) = delete;
 
        void handleEvent(const armem::wm::EntityInstance& memoryEntity);
 
        // Non-API.
    public:
        ~MemorySubscriber() override;
 
 
    protected:
        void handleEvents(const armem::wm::Memory& memory);
 
 
        void onEntityUpdate(const std::vector<armem::MemoryID>& snapshotIDs);
 
    private:
        const std::string callerId;
        armem::client::MemoryNameSystem& memoryNameSystem;
 
        armem::Time lastMemoryPoll;
 
        armem::client::Reader memoryReader;
 
        std::mutex eventHandlingMtx;
 
        armem::client::util::ScopedSubscriptionHandle subscriptionHandle;
    };
 
} // namespace armarx::navigation::client