diff --git a/src/vault/gear/activity-term.hpp b/src/vault/gear/activity-term.hpp
index 8ce0e4a32..acdda11fd 100644
--- a/src/vault/gear/activity-term.hpp
+++ b/src/vault/gear/activity-term.hpp
@@ -133,7 +133,7 @@ namespace gear {
* present) and to increase the Gate's latch counter. Moreover, the Argument,
* _must be a `NOTIFY`_ and will be modified to store the link to this receiving
* Gate; typically this function is actually invoked starting from the other
- * Term — the prerequisite — by invoking `appendNotificationTo(targetTerm)`.
+ * Term — the prerequisite — by invoking #appendNotificationTo(targetTerm).
*/
Term&
expectNotification (Activity& notificationSrc)
@@ -154,7 +154,9 @@ namespace gear {
Term&
appendNotificationTo (Term& targetTerm)
{
- UNIMPLEMENTED ("append NOTIFY and wire this through target.expectNotification()");
+ Activity& success = alloc_.create (Activity::NOTIFY);
+ insert (findTail (invoke_->next), &success);
+ targetTerm.expectNotification (success);
return *this;
}
@@ -174,7 +176,9 @@ namespace gear {
Term&
requireDirectActivation()
{
- UNIMPLEMENTED ("wire in self-Notification");
+ Activity& trigger = alloc_.create (Activity::NOTIFY);
+ expectNotification (trigger);
+ insert (post_, &trigger);
return *this;
}
diff --git a/tests/vault/gear/scheduler-activity-test.cpp b/tests/vault/gear/scheduler-activity-test.cpp
index 2d12adc38..5478eb4a7 100644
--- a/tests/vault/gear/scheduler-activity-test.cpp
+++ b/tests/vault/gear/scheduler-activity-test.cpp
@@ -491,6 +491,7 @@ namespace test {
.beforeInvocation("CTX-work").arg("5.155","")
.beforeInvocation("testJob") .arg("7.007",12345)
.beforeInvocation("CTX-done").arg("5.355",""));
+ cout << detector.showLog()<
-
-
-
+
+
+
-
-
+
+
-
+
-
+
-
+
-
-
+
+
@@ -80165,15 +80165,15 @@ Date: Thu Apr 20 18:53:17 2023 +0200
-
-
-
-
-
+
+
+
+
+
-
+
-
+