observers

[scpubgit/DKit.git] / lib / DX / RuleSet.pm

diff --git a/lib/DX/RuleSet.pm b/lib/DX/RuleSet.pm
index 5861116..13b6696 100644 (file)
--- a/lib/DX/RuleSet.pm
+++ b/lib/DX/RuleSet.pm
@@ -6,6 +6,7 @@ use DX::Op::MemberOf;
 use DX::Op::ApplyConstraint;
 use DX::Op::Return;
 use DX::Op::Cut;
+use DX::Op::Observe;
 use List::Util qw(reduce);
 
 has rules => (is => 'ro', default => sub { {} });
@@ -56,4 +57,12 @@ sub _expand_constrain {
   );
 }
 
+sub _expand_observe {
+  my ($self, $vars, $builder) = @_;
+  DX::Op::Observe->new(
+    vars => $vars,
+    builder => $builder,
+  );
+}
+
 1;