Compatibility fix with unreleased Timely

differential-dataflow/src/input.rs

@@ -198,7 +198,7 @@
 impl<T: Timestamp+Clone, D: Data, R: Semigroup+'static> InputSession<T, D, R> {
 
     /// Introduces a handle as collection.
     pub fn to_collection<G: TimelyInput>(&mut self, scope: &mut G) -> VecCollection<G, D, R>
     where
         G: ScopeParent<Timestamp=T>,
     {
@@ -258,7 +258,7 @@
     /// called, all buffers are flushed and timely dataflow is advised that some logical times are no longer possible.
     pub fn flush(&mut self) {
         self.handle.send_batch(&mut self.buffer);
-        if self.handle.epoch().less_than(&self.time) {
+        if self.handle.time().less_than(&self.time) {
             self.handle.advance_to(self.time.clone());
         }
     }
@@ -269,7 +269,7 @@
     /// the session is dropped or flushed. It is not correct to use this time as a basis for a computation's `step_while`
     /// method unless the session has just been flushed.
     pub fn advance_to(&mut self, time: T) {
-        assert!(self.handle.epoch().less_equal(&time));
+        assert!(self.handle.time().less_equal(&time));
         assert!(&self.time.less_equal(&time));
         self.time = time;
     }