Add dogs^3 to workspace and silence warnings

Cargo.toml

@@ -14,6 +14,9 @@ keywords = ["differential", "dataflow"]
 license = "MIT"
 readme = "README.md"
 
+[workspace]
+members = [".", "dogsdogsdogs"]
+
 [dev-dependencies]
 bincode = "1.3.1"
 rdkafka = "0.24"

dogsdogsdogs/src/lib.rs

@@ -37,11 +37,11 @@ pub trait PrefixExtender<G: Scope, R: Monoid+Multiply<Output = R>> {
     /// The type to be produced as extension.
     type Extension;
     /// Annotates prefixes with the number of extensions the relation would propose.
-    fn count(&mut self, &Collection<G, (Self::Prefix, usize, usize), R>, usize) -> Collection<G, (Self::Prefix, usize, usize), R>;
+    fn count(&mut self, prefixes: &Collection<G, (Self::Prefix, usize, usize), R>, index: usize) -> Collection<G, (Self::Prefix, usize, usize), R>;
     /// Extends each prefix with corresponding extensions.
-    fn propose(&mut self, &Collection<G, Self::Prefix, R>) -> Collection<G, (Self::Prefix, Self::Extension), R>;
+    fn propose(&mut self, prefixes: &Collection<G, Self::Prefix, R>) -> Collection<G, (Self::Prefix, Self::Extension), R>;
     /// Restricts proposed extensions by those the extender would have proposed.
-    fn validate(&mut self, &Collection<G, (Self::Prefix, Self::Extension), R>) -> Collection<G, (Self::Prefix, Self::Extension), R>;
+    fn validate(&mut self, extensions: &Collection<G, (Self::Prefix, Self::Extension), R>) -> Collection<G, (Self::Prefix, Self::Extension), R>;
 }
 
 pub trait ProposeExtensionMethod<G: Scope, P: ExchangeData+Ord, R: Monoid+Multiply<Output = R>> {

dogsdogsdogs/src/operators/half_join.rs

@@ -95,7 +95,7 @@ where
         let dout = (output_func(k, v1, v2), time.clone());
         Some((dout, initial.clone(), diff))
     };
-    half_join_internal_unsafe(stream, arrangement, frontier_func, comparison, |timer, count| false, output_func)
+    half_join_internal_unsafe(stream, arrangement, frontier_func, comparison, |_timer, _count| false, output_func)
 }
 
 /// An unsafe variant of `half_join` where the `output_func` closure takes

src/algorithms/graphs/sequential.rs

@@ -53,7 +53,7 @@ where
     F: Fn(&N, &[(&V, isize)])->V+'static
 {
 
-    let timer = ::std::time::Instant::now();
+    let _timer = ::std::time::Instant::now();
 
     // start iteration with None messages for all.
     state