Roland Conybeare
81a8a3dd84
subrepo: subdir: "xo-process" merged: "ff603471" upstream: origin: "git@github.com:Rconybea/xo-process.git" branch: "main" commit: "ff603471" git-subrepo: version: "0.4.9" origin: "???" commit: "???"
31 lines
1,010 B
C++
31 lines
1,010 B
C++
/* @file RealizationCallback.hpp */
|
|
|
|
#pragma once
|
|
|
|
#include "xo/reactor/Sink.hpp"
|
|
#include "xo/indentlog/print/pair.hpp"
|
|
//#include "time/Time.hpp"
|
|
#include <utility>
|
|
|
|
namespace xo {
|
|
namespace process {
|
|
/* callback for consuming stochastic process realizations */
|
|
template<typename T>
|
|
class RealizationCallback : public reactor::Sink1<std::pair<xo::time::utc_nanos, T>> {
|
|
public:
|
|
using utc_nanos = xo::time::utc_nanos;
|
|
|
|
public:
|
|
/* notification with process event (std::pair<utc_nanos, T>)
|
|
* see StochasticProcess<T>::event_type
|
|
*/
|
|
virtual void notify_ev(std::pair<utc_nanos, T> const & ev) override;
|
|
|
|
/* CallbackSet invokes these on add/remove events */
|
|
virtual void notify_add_callback() override {}
|
|
virtual void notify_remove_callback() override {}
|
|
}; /*RealizationCallback*/
|
|
} /*namespace process*/
|
|
} /*namespace xo*/
|
|
|
|
/* end RealizationCallback.hpp */
|