diff --git a/xo-process/include/xo/process/ExpProcess.hpp b/xo-process/include/xo/process/ExpProcess.hpp index 8cf6f526..c1dd10f3 100644 --- a/xo-process/include/xo/process/ExpProcess.hpp +++ b/xo-process/include/xo/process/ExpProcess.hpp @@ -27,14 +27,14 @@ namespace xo { public: static rp make(double scale, - ref::brw> exp_proc) { + bp> exp_proc) { return new ExpProcess(scale, exp_proc); } /*make*/ /* reflect ExpProcess object representation */ static void reflect_self(); - ref::brw> exponent_process() const { return exponent_process_.borrow(); } + bp> exponent_process() const { return exponent_process_.borrow(); } // ----- inherited from StochasticProcess<...> ----- @@ -80,7 +80,7 @@ namespace xo { virtual TaggedRcptr self_tp() override; private: - ExpProcess(double scale, ref::brw exp_proc) + ExpProcess(double scale, bp exp_proc) : scale_(scale), exponent_process_{exp_proc.get()} { ExpProcess::reflect_self(); diff --git a/xo-process/include/xo/process/Realization.hpp b/xo-process/include/xo/process/Realization.hpp index 35ced2df..03fdf3a8 100644 --- a/xo-process/include/xo/process/Realization.hpp +++ b/xo-process/include/xo/process/Realization.hpp @@ -11,18 +11,18 @@ namespace xo { namespace process { -// realization of a stochastic process. -// interface designed to allow for lazy evaluation. -// -// since a process connects a family of random variables, -// a single process can have a generally unbounded number of distinct realizations. -// -// implications: -// - can only realize (or observe) a finite set of instants. -// - given process evolves continuously, -// want ability to revisit intervals that may already contain some realized instants. -// - achieve this by allowing for caching behavior -// + /** realization of a stochastic process. + interface designed to allow for lazy evaluation. + + since a process connects a family of random variables, + a single process can have a generally unbounded number of distinct realizations. + + implications: + - can only realize (or observe) a finite set of instants. + - given process evolves continuously, + want ability to revisit intervals that may already contain some realized instants. + - achieve this by allowing for caching behavior + **/ template class Realization : public ref::Refcount { public: @@ -33,11 +33,11 @@ namespace xo { using KnownRange = decltype(std::views::all(KnownMap())); public: - static rp make(ref::brw> p) { + static rp make(bp> p) { return new Realization(p); } /*make*/ - ref::brw> process() const { return process_; } + bp> process() const { return process_; } utc_nanos t0() const { return process_->t0(); } @@ -54,7 +54,7 @@ namespace xo { // realized_range() -> iterator_range private: - Realization(ref::brw> p) : process_{p} {} + Realization(bp> p) : process_{p} {} private: /* stochastic process from which this realization is sampled */ diff --git a/xo-process/include/xo/process/RealizationSource.hpp b/xo-process/include/xo/process/RealizationSource.hpp index 932da915..b898c83a 100644 --- a/xo-process/include/xo/process/RealizationSource.hpp +++ b/xo-process/include/xo/process/RealizationSource.hpp @@ -163,7 +163,7 @@ namespace xo { << ">"; } /*display*/ - virtual void visit_direct_consumers(std::function)> const &) override { + virtual void visit_direct_consumers(std::function)> const &) override { assert(false); } @@ -289,7 +289,7 @@ namespace xo { // ----- Inherited from AbstractEventProcessor ----- - virtual void visit_direct_consumers(std::function)> const & fn) override { + virtual void visit_direct_consumers(std::function)> const & fn) override { for(auto const & x : *(this->ev_sink_addr())) fn(x.fn_.borrow());