subscription_impl.hpp

// Copyright (c) 2000-2023 TeamDev Ltd. All rights reserved.
// TeamDev PROPRIETARY and CONFIDENTIAL.
// Use is subject to license terms.
 
#ifndef MOLYBDEN_SUBSCRIPTION_IMPL_HPP
#define MOLYBDEN_SUBSCRIPTION_IMPL_HPP
 
#include <algorithm>
#include <functional>
#include <utility>
#include <vector>
 
#include "molybden/base/subscription.hpp"
 
namespace molybden {
namespace internal {
 
class SubscriptionObserver {
 public:
  virtual ~SubscriptionObserver() = default;
 
  virtual void onCanceled(int32_t id){};
};
 
template <typename T>
class SubscriptionImpl : public Subscription {
 public:
  SubscriptionImpl(int32_t id, std::function<void(const T& e)> observer);
 
  void notify(const T& event);
 
  void cancel() override;
 
  void setObserver(SubscriptionObserver* observer);
 
 private:
  int32_t id_;
  std::function<void(const T& e)> event_observer_;
  SubscriptionObserver* subscription_observer_;
};
 
template <typename T>
SubscriptionImpl<T>::SubscriptionImpl(int32_t id,
                                      std::function<void(const T&)> observer)
    : id_(id), event_observer_(std::move(observer)) {}
 
template <typename T>
void SubscriptionImpl<T>::notify(const T& event) {
  if (event_observer_) {
    event_observer_(event);
  }
}
 
template <typename T>
void SubscriptionImpl<T>::cancel() {
  event_observer_ = {};
  if (subscription_observer_) {
    subscription_observer_->onCanceled(id_);
  }
}
 
template <typename T>
void SubscriptionImpl<T>::setObserver(SubscriptionObserver* observer) {
  subscription_observer_ = observer;
}
 
}  // namespace internal
}  // namespace molybden
 
#endif  // MOLYBDEN_SUBSCRIPTION_IMPL_HPP