delegate.hpp

Go to the documentation of this file.

#pragma once
#include "any.hpp"
#include "argument_null_exception.hpp"
#include "async_result.hpp"
#include "iequatable.hpp"
#include "object.hpp"
#include "object_ref.hpp"
#include "usize.hpp"
#include <functional>
#include <vector>

namespace xtd {
  template<typename result_t>
  class delegate;
  
  template<typename result_t, typename ...arguments_t>
  class delegate<result_t(arguments_t...)>;
  
  using async_callback = xtd::delegate<void(async_result ar)>;
  
  template<typename result_t>
  class delegate<result_t()> : public xtd::object, public xtd::iequatable<delegate<result_t()>> {
    struct data {
      std::vector<std::function<result_t()>> functions;
    };
    
    class async_result_invoke : public xtd::iasync_result {
      struct data;
    public:
      async_result_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state);
      [[nodiscard]] auto async_state() const noexcept -> xtd::any_object override;
      [[nodiscard]] auto async_wait_handle() noexcept -> xtd::threading::wait_handle& override;
      [[nodiscard]] auto completed_synchronously() const noexcept -> bool override;
      [[nodiscard]] auto is_completed() const noexcept -> bool override;
      
      xtd::sptr<data> data_;
    };
    
  public:
    
    using function_t = std::function<result_t()>;
    using function_collection = std::vector<function_t>;
    
    
    delegate() = default;
    delegate(delegate&&) = default;
    delegate(const delegate& other) {*data_ = *other.data_;}
    delegate& operator =(const delegate& other) {*data_ = *other.data_; return *this;}
    
    delegate(const function_t& function) noexcept {data_->functions.push_back(function);} // Can't be explicit by design.
    
    template<class object1_t, typename object2_t>
    delegate(const object1_t& object, result_t(object2_t::*method)() const) noexcept {data_->functions.push_back(function_t(std::bind(method, const_cast<object1_t*>(&object))));}
    template<class object1_t, typename object2_t>
    delegate(const object1_t& object, result_t(object2_t::*method)()) noexcept {data_->functions.push_back(function_t(std::bind(method, const_cast<object1_t*>(&object))));}
    
    
    [[nodiscard]] auto count() const noexcept -> xtd::usize {return data_->functions.size();}
    
    [[nodiscard]] auto functions() const -> const function_collection& {return data_->functions;}
    
    [[nodiscard]] auto is_empty() const noexcept -> bool {return count() == 0;}
    
    [[nodiscard]] auto size() const noexcept -> xtd::usize {return count();}
    
    
    auto clear() -> void {data_->functions.clear();}
    
    [[nodiscard]] auto begin_invoke() -> async_result;
    [[nodiscard]] auto begin_invoke(xtd::async_callback async_callback) -> async_result;
    [[nodiscard]] auto begin_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state) -> async_result;
    
    auto end_invoke(async_result async) -> result_t;
    
    auto invoke() const -> result_t {return operator()();}
    
    [[nodiscard]] auto equals(const object& obj) const noexcept -> bool override {return is<delegate>(obj) && equals(static_cast<const delegate&>(obj));}
    [[nodiscard]] auto equals(const delegate& other) const noexcept -> bool override {
      if (data_->functions.size() != other.data_->functions.size()) return false;
      for (auto i = xtd::usize {0}; i < data_->functions.size(); i++)
        if (!are_equals(data_->functions[i], other.data_->functions[i])) return false;
      return true;
    }

    
    
    [[nodiscard]] static auto combine(const xtd::array<delegate>& delegates) noexcept -> delegate {
      auto result = delegate {};
      for (auto delegate : delegates)
        for (auto function : delegate.data_->functions)
          result.data_->functions.push_back(function);
      return result;
    }
    
    [[nodiscard]] static auto combine(const delegate& a, const delegate& b) noexcept -> delegate {return combine({a, b});}
    
    [[nodiscard]] static auto remove(const delegate& source, const delegate& value) noexcept -> delegate {
      auto result = source;
      std::for_each(value.data_->functions.begin(), value.data_->functions.end(), [&](const auto& function) {
        auto iterator = std::find_if(result.data_->functions.rbegin(), result.data_->functions.rend(), [&](const auto& item) {return are_equals(item, function);});
        if (iterator != result.data_->functions.rend()) result.data_->functions.erase((iterator + 1).base());
      });
      return result;
    }
    
    [[nodiscard]] static auto remove_all(const delegate& source, const delegate& value) noexcept -> delegate {
      delegate result = source;
      for (const function_t& function : value.data_->functions) {
        if (find(result.data_->functions.begin(), result.data_->functions.end(), function) != result.data_->functions.end()) {
          for (typename function_collection::reverse_iterator iterator = result.data_->functions.rbegin(); iterator != result.data_->functions.rend(); ++iterator) {
            if (are_equals(*iterator, function))
              result.data_->functions.erase((iterator + 1).base());
          }
        }
      }
      return result;
    }

    
    
    auto operator()() const -> result_t {
      if (data_->functions.size() == 0) {
        if constexpr(std::is_void_v<result_t>) return;
        else if constexpr(std::is_reference_v<result_t>) {
          using underlying_t = std::remove_reference_t<result_t>;
          if constexpr(std::is_const_v<underlying_t>) {
            static const underlying_t empty_value{};
            return empty_value;
          } else {
            static underlying_t empty_value{};
            return empty_value;
          }
        } else return result_t{};
      }
      
      for (auto i = xtd::usize {0}; i < data_->functions.size() - 1; i++) {
        if (data_->functions[i] == nullptr) xtd::helpers::throw_helper::throws(xtd::helpers::exception_case::argument_null);
        data_->functions[i]();
      }
      if (data_->functions.back() == nullptr) xtd::helpers::throw_helper::throws(xtd::helpers::exception_case::argument_null);
      return data_->functions.back()();
    }
    
    auto operator =(const function_t& function) noexcept -> delegate& {
      data_->functions.clear();
      data_->functions.push_back(function);
      return *this;
    }
    
    auto operator +(const delegate& other) const noexcept -> delegate {
      delegate result = *this;
      result += other;
      return result;
    }
    
    auto operator +(const function_t& function) const noexcept -> delegate {
      delegate result = *this;
      result += function;
      return result;
    }
    
    template<class fn_t>
    auto operator +(fn_t function) const noexcept -> delegate {
      delegate result = *this;
      result += function;
      return result;
    }
    
    auto operator +=(const delegate& other) noexcept -> delegate& {
      *this = delegate::combine(*this, other);
      return *this;
    }
    
    auto operator +=(const function_t& function) noexcept -> delegate& {
      *this = delegate::combine(*this, delegate(function));
      return *this;
    }
    
    template<class fn_t>
    auto operator +=(fn_t function) noexcept -> delegate& {
      *this = delegate::combine(*this, delegate(function));
      return *this;
    }
    
    auto operator -(const delegate& other) const noexcept -> delegate {
      delegate result = *this;
      result -= other;
      return result;
    }
    
    auto operator -(const function_t& function) const noexcept -> delegate {
      delegate result = *this;
      result -= function;
      return result;
    }
    
    template<class fn_t>
    auto operator -(fn_t function) const noexcept -> delegate {
      delegate result = *this;
      result -= function;
      return result;
    }
    
    auto operator -=(const delegate& other) noexcept -> delegate& {
      *this = delegate::remove(*this, other);
      return *this;
    }
    
    auto operator -=(const function_t& function) noexcept -> delegate& {
      *this = delegate::remove(*this, delegate(function));
      return *this;
    }
    
    template<class fn_t>
    auto operator -=(fn_t function) noexcept -> delegate& {
      *this = delegate::remove(*this, delegate(function));
      return *this;
    }
    
  private:
    [[nodiscard]] static auto are_equals(const std::function<result_t()>& fct1, const std::function<result_t()>& fct2) noexcept -> bool {return fct1.target_type() == fct2.target_type() && (fct1.template target<result_t(*)()>() == fct2.template target<result_t(*)()>() || *fct1.template target<result_t(*)()>() == *fct2.template target<result_t(*)()>());}
    [[nodiscard]] static auto find(typename function_collection::const_iterator begin, typename function_collection::const_iterator end, const function_t& function) noexcept -> typename function_collection::const_iterator {
      auto iterator = std::find_if(begin, end, [&](const auto& item) {return are_equals(item, function);});
      if (iterator != end) return iterator;
      return end;
    }
    
    xtd::sptr<data> data_ = xtd::new_sptr<data>();
  };
  
  template<class result_t, typename ...arguments_t>
  class delegate<result_t(arguments_t...)> : public object, public xtd::iequatable<delegate<result_t(arguments_t...)>> {
    struct data {
      std::vector<std::function<result_t()>> no_arguments_functions;
      std::vector<std::function<result_t(arguments_t...)>> functions;
    };
    
    class async_result_invoke : public xtd::iasync_result {
      struct data;
    public:
      async_result_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state);
      [[nodiscard]] auto async_state() const noexcept -> xtd::any_object override;
      [[nodiscard]] auto async_wait_handle() noexcept -> xtd::threading::wait_handle& override;
      [[nodiscard]] auto completed_synchronously() const noexcept -> bool override;
      [[nodiscard]] auto is_completed() const noexcept -> bool override;
      
      xtd::sptr<data> data_;
    };
    
  public:
    
    using no_arguments_function_t = std::function<result_t()>;
    using function_t = std::function<result_t(arguments_t...)>;
    using no_arguments_function_collection = std::vector<no_arguments_function_t>;
    using function_collection = std::vector<function_t>;
    
    
    delegate() = default;
    delegate(delegate&&) = default;
    delegate(const delegate& other) {*data_ = *other.data_;}
    delegate& operator =(const delegate& other) {*data_ = *other.data_; return *this;}
    delegate(const delegate<result_t()>& delegate) noexcept {data_->no_arguments_functions = delegate.functions();}
    
    delegate(const function_t& function) noexcept {data_->functions.push_back(function);} // Can't be explicit by design.
    
    delegate(const no_arguments_function_t& function) noexcept {data_->no_arguments_functions.push_back(function);} // Can't be explicit by design.
    
    template<class object1_t, typename object2_t>
    delegate(const object1_t& object, result_t(object2_t::*method)() const) noexcept {data_->functions.push_back(function_t(std::bind(method, const_cast<object1_t*>(&object))));}
    
    template<class object1_t, typename object2_t>
    delegate(const object1_t& object, result_t(object2_t::*method)()) noexcept {data_->functions.push_back(function_t(std::bind(method, const_cast<object1_t*>(&object))));}
    
    template<class object1_t, typename object2_t, typename... args_t>
    delegate(const object1_t& object, result_t(object2_t::*method)(args_t...) const) noexcept {data_->functions.push_back(function_t(std::bind_front(method, const_cast<object1_t*>(&object))));}
 
    template<class object1_t, typename object2_t, typename... args_t>
    delegate(const object1_t& object, result_t(object2_t::*method)(args_t...)) noexcept {data_->functions.push_back(function_t(std::bind_front(method, const_cast<object1_t*>(&object))));}
    
    
    [[nodiscard]] auto count() const noexcept -> xtd::usize {return data_->functions.size() + data_->no_arguments_functions.size();}
    
    [[nodiscard]] auto no_arguments_functions() const -> const no_arguments_function_collection& {return data_->no_arguments_functions;}
    
    [[nodiscard]] auto functions() const -> const function_collection& {return data_->functions;}
    
    [[nodiscard]] auto is_empty() const noexcept -> bool {return count() == 0;}
    
    [[nodiscard]] auto size() const noexcept -> xtd::usize {return count();}
    
    
    [[nodiscard]] auto begin_invoke(arguments_t&&... arguments) -> async_result;
    [[nodiscard]] auto begin_invoke(xtd::async_callback async_callback, arguments_t&&... arguments) -> async_result;
    [[nodiscard]] auto begin_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state, arguments_t&&... arguments) -> async_result;
    
    auto end_invoke(async_result async) -> result_t;
    
    auto invoke(arguments_t&&... arguments) const -> result_t {return operator()(arguments...);}
    
    [[nodiscard]] auto equals(const object& obj) const noexcept -> bool override {return is<delegate>(obj) && equals(static_cast<const delegate&>(obj));}
    [[nodiscard]] auto equals(const delegate& other) const noexcept -> bool override {
      if (data_->functions.size() != other.data_->functions.size() || data_->no_arguments_functions.size() != other.data_->no_arguments_functions.size()) return false;
      for (auto i = xtd::usize {0}; i < data_->no_arguments_functions.size(); i++)
        if (!are_equals(data_->no_arguments_functions[i], other.data_->no_arguments_functions[i])) return false;
      for (auto i = xtd::usize {0}; i < data_->functions.size(); i++)
        if (!are_equals(data_->functions[i], other.data_->functions[i])) return false;
      return true;
    }

    
    
    [[nodiscard]] static auto combine(const xtd::array<delegate>& delegates) noexcept -> delegate {
      auto result = delegate {};
      for (auto delegate : delegates) {
        for (auto function : delegate.data_->no_arguments_functions)
          result.data_->no_arguments_functions.push_back(function);
        for (auto function : delegate.data_->functions)
          result.data_->functions.push_back(function);
      }
      return result;
    }
    
    [[nodiscard]] static auto combine(const delegate& a, const delegate& b) noexcept -> delegate {return combine({a, b});}
    
    [[nodiscard]] static auto remove(const delegate& source, const delegate& value) noexcept -> delegate {
      auto result = source;
      std::for_each(value.data_->no_arguments_functions.begin(), value.data_->no_arguments_functions.end(), [&](const auto& no_arguments_function) {
        auto iterator = std::find_if(result.data_->no_arguments_functions.rbegin(), result.data_->no_arguments_functions.rend(), [&](const auto& item) {return are_equals(item, no_arguments_function);});
        if (iterator != result.data_->no_arguments_functions.rend()) result.data_->no_arguments_functions.erase((iterator + 1).base());
      });
      
      std::for_each(value.data_->functions.begin(), value.data_->functions.end(), [&](const auto& function) {
        auto iterator = std::find_if(result.data_->functions.rbegin(), result.data_->functions.rend(), [&](const auto& item) {return are_equals(item, function);});
        if (iterator != result.data_->functions.rend()) result.data_->functions.erase((iterator + 1).base());
      });
      return result;
    }
    
    [[nodiscard]] static auto remove_all(const delegate& source, const delegate& value) noexcept -> delegate {
      auto result = source;
      for (auto function : value.data_->no_arguments_functions) {
        if (find(result.data_->no_arguments_functions.begin(), result.data_->no_arguments_functions.end(), function) != result.data_->no_arguments_functions.end()) {
          for (typename function_collection::reverse_iterator iterator = result.data_->no_arguments_functions.rbegin(); iterator != result.data_->no_arguments_functions.rend(); ++iterator) {
            if (are_equals(*iterator, function))
              result.data_->no_arguments_functions.erase((iterator + 1).base());
          }
        }
      }
      
      for (auto function : value.data_->functions) {
        if (find(result.data_->functions.begin(), result.data_->functions.end(), function) != result.data_->functions.end()) {
          for (auto iterator = result.data_->functions.rbegin(); iterator != result.data_->functions.rend(); ++iterator) {
            if (are_equals(*iterator, function))
              result.data_->functions.erase((iterator + 1).base());
          }
        }
      }
      return result;
    }

    
    
    auto operator()(arguments_t... arguments) const -> result_t {
      if (data_->no_arguments_functions.size() == 0 && data_->functions.size() == 0) {
        if constexpr(std::is_void_v<result_t>) return;
        else if constexpr(std::is_reference_v<result_t>) {
          using underlying_t = std::remove_reference_t<result_t>;
          if constexpr(std::is_const_v<underlying_t>) {
            static const underlying_t empty_value{};
            return empty_value;
          } else {
            static underlying_t empty_value{};
            return empty_value;
          }
        } else return result_t{};
      }
      
      if (data_->no_arguments_functions.size()) {
        for (auto i = xtd::usize {0}; i < data_->no_arguments_functions.size() - (data_->functions.size() == 0 ? 1 : 0); i++) {
          if (data_->no_arguments_functions[i] == nullptr) xtd::helpers::throw_helper::throws(xtd::helpers::exception_case::argument_null);
          data_->no_arguments_functions[i]();
        }
        
        if (data_->functions.size() == 0) {
          if (data_->no_arguments_functions.back() == nullptr) xtd::helpers::throw_helper::throws(xtd::helpers::exception_case::argument_null);
          return data_->no_arguments_functions.back()();
        }
      }
      
      for (auto i = xtd::usize {0}; i < data_->functions.size() - 1; i++) {
        if (data_->functions[i] == nullptr) xtd::helpers::throw_helper::throws(xtd::helpers::exception_case::argument_null);
        data_->functions[i](arguments...);
      }
      if (data_->functions.back() == nullptr) xtd::helpers::throw_helper::throws(xtd::helpers::exception_case::argument_null);
      return data_->functions.back()(arguments...);
    }

    
    template<class type_t>
    auto operator =(const type_t& function) noexcept -> delegate& {
      data_->no_arguments_functions.clear();
      data_->functions.clear();
      data_->functions.push_back(function_t(function));
      return *this;
    }
    
    auto operator =(const function_t& function) noexcept -> delegate& {
      data_->no_arguments_functions.clear();
      data_->functions.clear();
      data_->functions.push_back(function);
      return *this;
    }
    
    auto operator =(const no_arguments_function_t& function) noexcept -> delegate& {
      data_->no_arguments_functions.clear();
      data_->functions.clear();
      data_->no_arguments_functions.push_back(function);
      return *this;
    }
    
    auto operator +(const delegate& other) const noexcept -> delegate {
      delegate result = *this;
      result += other;
      return result;
    }
    
    auto operator +(const no_arguments_function_t& function) const noexcept -> delegate {
      delegate result = *this;
      result += function;
      return result;
    }
    
    auto operator +(const function_t& function) const noexcept -> delegate {
      delegate result = *this;
      result += function;
      return result;
    }
    
    template<class fn_t>
    auto operator +(fn_t function) const noexcept -> delegate {
      delegate result = *this;
      result += function;
      return result;
    }
    
    auto operator +=(const delegate& other) noexcept -> delegate& {
      *this = delegate::combine(*this, other);
      return *this;
    }
    
    auto operator +=(const no_arguments_function_t& function) noexcept -> delegate& {
      *this = delegate::combine(*this, delegate(function));
      return *this;
    }
    
    auto operator +=(const function_t& function) noexcept -> delegate& {
      *this = delegate::combine(*this, delegate(function));
      return *this;
    }
    
    template<class fn_t>
    auto operator +=(fn_t function) noexcept -> delegate& {
      *this = delegate::combine(*this, delegate(function));
      return *this;
    }
    
    auto operator -(const delegate& other) const noexcept -> delegate {
      delegate result = *this;
      result -= other;
      return result;
    }
    
    auto operator -(const no_arguments_function_t& function) const noexcept -> delegate {
      delegate result = *this;
      result -= function;
      return result;
    }
    
    auto operator -(const function_t& function) const noexcept -> delegate {
      delegate result = *this;
      result -= function;
      return result;
    }
    
    template<class fn_t>
    auto operator -(fn_t function) const noexcept -> delegate {
      delegate result = *this;
      result -= function;
      return result;
    }
    
    auto operator -=(const delegate& other) noexcept -> delegate& {
      *this = delegate::remove(*this, other);
      return *this;
    }
    
    auto operator -=(const no_arguments_function_t& function) noexcept -> delegate& {
      *this = delegate::remove(*this, delegate(function));
      return *this;
    }
    
    auto operator -=(const function_t& function) noexcept -> delegate& {
      *this = delegate::remove(*this, delegate(function));
      return *this;
    }
    
    template<class fn_t>
    auto operator -=(fn_t function) noexcept -> delegate& {
      *this = delegate::remove(*this, delegate(function));
      return *this;
    }
    
  private:
    struct delegate_async_state;
    
    [[nodiscard]] static auto are_equals(const std::function<result_t(arguments_t...)>& fct1, const std::function<result_t(arguments_t...)>& fct2) noexcept -> bool {
      return fct1.target_type() == fct2.target_type() && (fct1.template target<result_t(*)(arguments_t...)>() == fct2.template target<result_t(*)(arguments_t...)>() || *fct1.template target<result_t(*)(arguments_t...)>() == *fct2.template target<result_t(*)(arguments_t...)>());
    }
    
    [[nodiscard]] static auto are_equals(const std::function<result_t()>& fct1, const std::function<result_t()>& fct2) noexcept -> bool {
      return fct1.target_type() == fct2.target_type() && (fct1.template target<result_t(*)()>() == fct2.template target<result_t(*)()>() || *fct1.template target<result_t(*)()>() == *fct2.template target<result_t(*)()>());
    }
    
    [[nodiscard]] static auto find(typename no_arguments_function_collection::const_iterator begin, typename no_arguments_function_collection::const_iterator end, const no_arguments_function_t& function) noexcept -> typename no_arguments_function_collection::const_iterator {
      auto iterator = std::find_if(begin, end, [&](const auto& item) {return are_equals(item, function);});
      if (iterator != end) return iterator;
      return end;
    }
    
    [[nodiscard]] static auto find(typename function_collection::const_iterator begin, typename function_collection::const_iterator end, const function_t& function) noexcept -> typename function_collection::const_iterator {
      auto iterator = std::find_if(begin, end, [&](const auto& item) {return are_equals(item, function);});
      if (iterator != end) return iterator;
      return end;
    }
    
    xtd::sptr<data> data_ = xtd::new_sptr<data>();
  };
}

#define delegate_ \
  [&]
 
// Required for begin_invoke and end_invoke methods implementation.
#include "threading/thread_pool.hpp"