Merge pull request #225 from TimelyDataflow/sequencer_drop

Activate on drop
TimelyDataflow · Feb 6, 2019 · 47b254d · 47b254d
2 parents 06e5cd1 + 5c559e0
commit 47b254d
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/synchronization/sequence.rs b/src/synchronization/sequence.rs
@@ -221,3 +221,14 @@ impl<T> Iterator for Sequencer<T> {
         self.recv.borrow_mut().pop_front()
     }
 }
+
+// We should activate on drop, as this will cause the source to drop its capability.
+impl<T> Drop for Sequencer<T> {
+    fn drop(&mut self) {
+        self.activator
+            .borrow()
+            .as_ref()
+            .expect("Sequencer.activator unavailable")
+            .activate()
+    }
+}