Subscription.hpp

Go to the documentation of this file.

// Copyright (c) 2026 EduArt Robotik GmbH

 
#pragma once
 
#include <functional>
#include <vector>
 
#include "sensorring/subscription/SubscriberToken.hpp"
 
namespace eduart {
 
namespace subscription {

class Subscription {
public:
  Subscription() noexcept = default;

  Subscription(SubscriberToken token, std::function<void()> unsubscribe)
      : _token(token)
      , _unsubscribe(std::move(unsubscribe)) {}

  Subscription(Subscription&& other) noexcept : _token(other._token), _unsubscribe(std::move(other._unsubscribe)) {
    other._token       = SubscriberToken{};
    other._unsubscribe = nullptr;
  }

  Subscription& operator=(Subscription&& other) noexcept {
    if (this != &other) {
      cancel();
      _token             = other._token;
      _unsubscribe       = std::move(other._unsubscribe);
      other._token       = SubscriberToken{};
      other._unsubscribe = nullptr;
    }
    return *this;
  }
 
  Subscription(const Subscription&)            = delete;
  Subscription& operator=(const Subscription&) = delete;

  ~Subscription() { cancel(); }

  void cancel() noexcept {
    if (_unsubscribe) {
      _unsubscribe();
      _unsubscribe = nullptr;
    }
    _token = SubscriberToken{};
  }

  bool isActive() const noexcept { return _token.isValid(); }

  SubscriberToken token() const noexcept { return _token; }
 
private:
  SubscriberToken _token;
  std::function<void()> _unsubscribe;
};
 
} // namespace subscription
 
} // namespace eduart