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