future.h

#pragma once
 
#include <memory>
 
#include <ucp/api/ucp.h>
 
#include <ucxx/notifier.h>
 
namespace ucxx {

class Future : public std::enable_shared_from_this<Future> {
 protected:
  std::shared_ptr<Notifier> _notifier{nullptr};  

  explicit Future(std::shared_ptr<Notifier> notifier) : _notifier(notifier) {}
 
 public:
  Future()                         = delete;
  Future(const Future&)            = delete;
  Future& operator=(Future const&) = delete;
  Future(Future&& o)               = delete;
  Future& operator=(Future&& o)    = delete;

  virtual ~Future() {}

  virtual void notify(ucs_status_t status) = 0;

  virtual void set(ucs_status_t status) = 0;

  [[nodiscard]] virtual void* getHandle() = 0;

  [[nodiscard]] virtual void* release() = 0;
};
 
}  // namespace ucxx