(&self, event_type: &str, properties: serde_json::Value)
| 525 | } |
| 526 | |
| 527 | pub async fn do_publish_bus(&self, event_type: &str, properties: serde_json::Value) { |
| 528 | if let Some(ref callback) = self.publish_bus { |
| 529 | callback(event_type.to_string(), properties).await; |
| 530 | } |
| 531 | } |
| 532 | |
| 533 | pub fn with_update_part<F, Fut>(mut self, callback: F) -> Self |
| 534 | where |