Policy SDK には、1 つのオブザーバー クラスが含まれています。 オブザーバー メンバーは仮想であり、非同期操作のコールバックを処理するためにオーバーライドする必要があります。
非同期操作が完了すると、結果に対応する OnXxx() メンバー関数が呼び出されます。
mip::Profile::Observer の例としては、OnLoadSuccess()、OnLoadFailure()、OnAddEngineSuccess() があります。
次の例は、PROMISE/future パターンを示しています。これは SDK サンプルでも使用され、目的のコールバック動作を実装するために拡張できます。
プロファイル オブザーバーの実装
次の例では、ProfileObserverから派生したクラスmip::Profile::Observerを作成しました。 メンバー関数は、サンプル全体で使用される future/promise パターンを使用するようにオーバーライドされています。
注: 以下のサンプルは部分的にのみ実装され、 mip::ProfileEngine 関連オブザーバーのオーバーライドは含まれません。
profile_observer.h
ヘッダーでは、ProfileObserverから派生したmip::Profile::Observerを定義し、各メンバー関数をオーバーライドします。
class ProfileObserver final : public mip::Profile::Observer {
public:
ProfileObserver() { }
void OnLoadSuccess(const std::shared_ptr<mip::Profile>& profile, const std::shared_ptr<void>& context) override;
void OnLoadFailure(const std::exception_ptr& error, const std::shared_ptr<void>& context) override;
//TODO: Implement remaining members
};
profile_observer.cpp
実装自体では、各オブザーバー メンバー関数に対して実行するアクションを定義します。
各メンバーは、2 つのパラメーターを受け取ります。 1 つ目は、関数によって処理されるクラスへの共有ポインターです。
ProfileObserver::OnLoadSuccessはmip::Profileを受け取るものと考えられます。
ProfileObserver::OnAddEngineSuccess は mip::ProfileEngineを期待します。
2 つ目は、 コンテキストへの共有ポインターです。 この実装では、コンテキストはstd::promiseとして渡されるshared_ptr<void>への参照です。 関数の最初の行は、これを std::promiseにキャストし、 promiseというオブジェクトに格納します。
最後に、 promise->set_value() を設定し、 mip::Profile オブジェクトを渡すことで、将来の準備が整います。
#include "profile_observer.h"
#include <future>
//Called when Profile is successfully loaded
void ProfileObserver::OnLoadSuccess(const std::shared_ptr<mip::Profile>& profile, const std::shared_ptr<void>& context) {
//cast context to promise
auto promise = std::static_pointer_cast<std::promise<std::shared_ptr<mip::Profile>>>(context);
//set promise value to profile
promise->set_value(profile);
}
//Called when Profile fails to load
void ProfileObserver::OnLoadFailure(const std::exception_ptr& error, const std::shared_ptr<void>& context) {
auto promise = std::static_pointer_cast<std::promise<std::shared_ptr<mip::Profile>>>(context);
promise->set_exception(error);
}
//TODO: Implement remaining observer members
非同期操作を実行すると、オブザーバーの実装が設定コンストラクターまたは非同期関数自体に渡されます。