FRP: require lock when adding dependencies

2 files changed, 5 insertions, 4 deletions

diff --git a/include/erebos/frp.h b/include/erebos/frp.h
index 28a8f63..72b5cc9 100644
--- a/include/erebos/frp.h
+++ b/include/erebos/frp.h
@@ -89,7 +89,7 @@ public:
 	virtual ~BhvImplBase();
 
 protected:
-	void dependsOn(shared_ptr<BhvImplBase> other);
+	void dependsOn(const BhvCurTime &, shared_ptr<BhvImplBase> other);
 	void updated(const BhvCurTime &);
 	virtual bool needsUpdate(const BhvCurTime &) const;
 	virtual void doUpdate(const BhvCurTime &);
@@ -251,9 +251,10 @@ private:
 template<typename A, typename B, typename C>
 BhvFun<A, C> operator>>(const BhvFun<A, B> & f, const BhvFun<B, C> & g)
 {
+	BhvCurTime ctime;
 	auto impl = make_shared<BhvComp<A, B, C>>(f, g);
-	impl->dependsOn(f.impl);
-	impl->dependsOn(g.impl);
+	impl->dependsOn(ctime, f.impl);
+	impl->dependsOn(ctime, g.impl);
 	return impl;
 }
 
diff --git a/src/frp.cpp b/src/frp.cpp
index 1d377dd..eba104d 100644
--- a/src/frp.cpp
+++ b/src/frp.cpp
@@ -73,7 +73,7 @@ BhvCurTime & BhvCurTime::operator=(BhvCurTime && other)
 
 BhvImplBase::~BhvImplBase() = default;
 
-void BhvImplBase::dependsOn(shared_ptr<BhvImplBase> other)
+void BhvImplBase::dependsOn(const BhvCurTime &, shared_ptr<BhvImplBase> other)
 {
 	depends.push_back(other);
 	other->rdepends.push_back(shared_from_this());