Drops all shutdown handles associated with the specified query, resulting in its dataflow getting cleaned up.
(&mut self, name: &str)
| 337 | /// Drops all shutdown handles associated with the specified |
| 338 | /// query, resulting in its dataflow getting cleaned up. |
| 339 | fn shutdown_query(&mut self, name: &str) { |
| 340 | info!("Shutting down {}", name); |
| 341 | self.shutdown_handles.remove(name); |
| 342 | } |
| 343 | |
| 344 | /// Handle a Transact request. |
| 345 | pub fn transact( |