(&self, file_path: String)
| 506 | } |
| 507 | |
| 508 | pub async fn do_file_time_read(&self, file_path: String) -> Result<(), ToolError> { |
| 509 | if let Some(ref callback) = self.file_time_read { |
| 510 | callback(self.session_id.clone(), file_path).await |
| 511 | } else { |
| 512 | Ok(()) |
| 513 | } |
| 514 | } |
| 515 | |
| 516 | pub fn with_publish_bus<F, Fut>(mut self, callback: F) -> Self |
| 517 | where |