diff --git a/codex-rs/mcp-server/src/outgoing_message.rs b/codex-rs/mcp-server/src/outgoing_message.rs index f408ca0a45..82f64e35c3 100644 --- a/codex-rs/mcp-server/src/outgoing_message.rs +++ b/codex-rs/mcp-server/src/outgoing_message.rs @@ -119,9 +119,6 @@ impl OutgoingMessageSender { params: Some(params.clone()), }) .await; - - self.send_event_as_notification_new_schema(event, Some(params.clone())) - .await; } pub(crate) async fn send_notification(&self, notification: OutgoingNotification) { @@ -129,19 +126,6 @@ impl OutgoingMessageSender { let _ = self.sender.send(outgoing_message).await; } - // should be backwards compatible. - // it will replace send_event_as_notification eventually. - async fn send_event_as_notification_new_schema( - &self, - event: &Event, - params: Option, - ) { - let outgoing_message = OutgoingMessage::Notification(OutgoingNotification { - method: event.msg.to_string(), - params, - }); - let _ = self.sender.send(outgoing_message).await; - } pub(crate) async fn send_error(&self, id: RequestId, error: JSONRPCErrorError) { let outgoing_message = OutgoingMessage::Error(OutgoingError { id, error }); let _ = self.sender.send(outgoing_message).await;