diff --git a/timely/src/dataflow/operators/core/capture/event.rs b/timely/src/dataflow/operators/core/capture/event.rs index 5e667c282..35dc158cb 100644 --- a/timely/src/dataflow/operators/core/capture/event.rs +++ b/timely/src/dataflow/operators/core/capture/event.rs @@ -24,7 +24,7 @@ pub enum Event { /// This method is not simply an iterator because of the lifetime in the result. pub trait EventIterator { /// Iterates over `Cow>` elements. - fn next(&mut self) -> Option>>; + fn next(&mut self) -> Option>>; } /// Receives `Event` events. diff --git a/timely/src/progress/frontier.rs b/timely/src/progress/frontier.rs index 7929e2cb1..7105c665f 100644 --- a/timely/src/progress/frontier.rs +++ b/timely/src/progress/frontier.rs @@ -629,7 +629,7 @@ pub trait MutableAntichainFilter { /// /// assert!(changes == vec![(1, -1), (2, 1)]); /// ``` - fn filter_through(self, antichain: &mut MutableAntichain) -> smallvec::Drain<[(T,i64); 2]>; + fn filter_through(self, antichain: &mut MutableAntichain) -> smallvec::Drain<'_, [(T,i64); 2]>; } impl> MutableAntichainFilter for I { diff --git a/timely/src/worker.rs b/timely/src/worker.rs index 77149a737..999754ecd 100644 --- a/timely/src/worker.rs +++ b/timely/src/worker.rs @@ -201,7 +201,7 @@ pub trait AsWorker : Scheduler { /// The next worker-unique identifier to be allocated. fn peek_identifier(&self) -> usize; /// Provides access to named logging streams. - fn log_register(&self) -> Option<::std::cell::RefMut>; + fn log_register(&self) -> Option>; /// Acquires a logger by name, if the log register exists and the name is registered. /// /// For a more precise understanding of why a result is `None` one can use the direct functions.