(
&self,
state: Arc<dyn Any + Send + Sync>,
)
| 522 | } |
| 523 | |
| 524 | fn with_new_state( |
| 525 | &self, |
| 526 | state: Arc<dyn Any + Send + Sync>, |
| 527 | ) -> Option<Arc<dyn ExecutionPlan>> { |
| 528 | self.data_source |
| 529 | .with_new_state(state) |
| 530 | .map(|new_data_source| { |
| 531 | Arc::new(self.clone().with_data_source(new_data_source)) |
| 532 | as Arc<dyn ExecutionPlan> |
| 533 | }) |
| 534 | } |
| 535 | |
| 536 | fn reset_state(self: Arc<Self>) -> Result<Arc<dyn ExecutionPlan>> { |
| 537 | let mut new_exec = Arc::unwrap_or_clone(self); |
nothing calls this directly
no test coverage detected