(&self)
| 162 | |
| 163 | impl<T: Timestamp> Clone for Handle<T> { |
| 164 | fn clone(&self) -> Self { |
| 165 | Handle { |
| 166 | frontier: Rc::clone(&self.frontier), |
| 167 | handle_frontier: Antichain::new(), |
| 168 | notify: Rc::clone(&self.notify), |
| 169 | activators: Rc::clone(&self.activators), |
| 170 | } |
| 171 | } |
| 172 | } |
| 173 | |
| 174 | /// Creates a stream that flows progress updates from a probe. |