Half join tactic

dogsdogsdogs/examples/delta_query2.rs

@@ -43,7 +43,7 @@ fn main() {
                     changes1,
                     forward2,
                     closure,
-                    |t1,t2| t1.lt(t2),  // This one ignores concurrent updates.
+                    true,   // This one ignores concurrent updates.
                     |key, val1, val2| (key.clone(), (val1.clone(), val2.clone())),
                 );
 
@@ -52,7 +52,7 @@ fn main() {
                     changes2,
                     forward1,
                     closure,
-                    |t1,t2| t1.le(t2),  // This one can "see" concurrent updates.
+                    false,  // This one can "see" concurrent updates.
                     |key, val1, val2| (key.clone(), (val2.clone(), val1.clone())),
                 );
 

dogsdogsdogs/src/operators/count.rs

@@ -63,16 +63,10 @@ where
         builder.push_into(((triple, payload.clone()), initial.clone(), diff1.clone()));
     };
 
-    use crate::operators::half_join::half_join_internal_unsafe as half_join_unsafe;
-    // Branch once here, so that each comparison monomorphizes rather than testing `strict` at
-    // every timestamp. The cost is instantiating `half_join` twice.
-    if strict {
-        half_join_unsafe::<_, _, _, _, _, _, _, _, Output<P, Tr::Time, R>>(
-            requests, arrangement, frontier_func, |t1, t2| t1 < t2, |_timer, _count| false, output_func)
-    }
-    else {
-        half_join_unsafe::<_, _, _, _, _, _, _, _, Output<P, Tr::Time, R>>(
-            requests, arrangement, frontier_func, |t1, t2| t1 <= t2, |_timer, _count| false, output_func)
-    }
+    use crate::operators::half_join::cursors::half_join_internal_unsafe as half_join_unsafe;
+    // `strict` now reaches the join as a value rather than as a comparison closure, so there is
+    // nothing left to monomorphize by branching here; the test is made per arrangement time.
+    half_join_unsafe::<_, _, _, _, _, _, _, Output<P, Tr::Time, R>>(
+        requests, arrangement, frontier_func, strict, |_timer, _count| false, output_func)
     .as_collection()
 }