diff --git a/src/agents/realtime/model_events.py b/src/agents/realtime/model_events.py
index 43b0dd025..5aeadc0f9 100644
--- a/src/agents/realtime/model_events.py
+++ b/src/agents/realtime/model_events.py
@@ -156,6 +156,15 @@ class RealtimeModelExceptionEvent:
     type: Literal["exception"] = "exception"
 
 
+@dataclass
+class RealtimeModelRawServerEvent:
+    """Raw events forwarded from the server."""
+
+    data: Any
+
+    type: Literal["raw_server_event"] = "raw_server_event"
+
+
 # TODO (rm) Add usage events
 
 
@@ -174,4 +183,5 @@ class RealtimeModelExceptionEvent:
     RealtimeModelTurnEndedEvent,
     RealtimeModelOtherEvent,
     RealtimeModelExceptionEvent,
+    RealtimeModelRawServerEvent,
 ]
diff --git a/src/agents/realtime/openai_realtime.py b/src/agents/realtime/openai_realtime.py
index 01a246ad2..d0189ed6b 100644
--- a/src/agents/realtime/openai_realtime.py
+++ b/src/agents/realtime/openai_realtime.py
@@ -86,6 +86,7 @@
     RealtimeModelInputAudioTranscriptionCompletedEvent,
     RealtimeModelItemDeletedEvent,
     RealtimeModelItemUpdatedEvent,
+    RealtimeModelRawServerEvent,
     RealtimeModelToolCallEvent,
     RealtimeModelTranscriptDeltaEvent,
     RealtimeModelTurnEndedEvent,
@@ -447,6 +448,7 @@ async def _cancel_response(self) -> None:
             self._ongoing_response = False
 
     async def _handle_ws_event(self, event: dict[str, Any]):
+        await self._emit_event(RealtimeModelRawServerEvent(data=event))
         try:
             if "previous_item_id" in event and event["previous_item_id"] is None:
                 event["previous_item_id"] = ""  # TODO (rm) remove
diff --git a/src/agents/realtime/session.py b/src/agents/realtime/session.py
index d5d4d8046..5c9d77055 100644
--- a/src/agents/realtime/session.py
+++ b/src/agents/realtime/session.py
@@ -274,6 +274,8 @@ async def on_event(self, event: RealtimeModelEvent) -> None:
             self._stored_exception = event.exception
         elif event.type == "other":
             pass
+        elif event.type == "raw_server_event":
+            pass
         else:
             assert_never(event)
 
diff --git a/tests/realtime/test_openai_realtime.py b/tests/realtime/test_openai_realtime.py
index 704d95d40..4c410bf6e 100644
--- a/tests/realtime/test_openai_realtime.py
+++ b/tests/realtime/test_openai_realtime.py
@@ -180,9 +180,9 @@ async def test_handle_malformed_json_logs_error_continues(self, model):
         # Malformed JSON should not crash the handler
         await model._handle_ws_event("invalid json {")
 
-        # Should emit error event to listeners
-        mock_listener.on_event.assert_called_once()
-        error_event = mock_listener.on_event.call_args[0][0]
+        # Should emit raw server event and error event to listeners
+        assert mock_listener.on_event.call_count == 2
+        error_event = mock_listener.on_event.call_args_list[1][0][0]
         assert error_event.type == "error"
 
     @pytest.mark.asyncio
@@ -195,9 +195,9 @@ async def test_handle_invalid_event_schema_logs_error(self, model):
 
         await model._handle_ws_event(invalid_event)
 
-        # Should emit error event to listeners
-        mock_listener.on_event.assert_called_once()
-        error_event = mock_listener.on_event.call_args[0][0]
+        # Should emit raw server event and error event to listeners
+        assert mock_listener.on_event.call_count == 2
+        error_event = mock_listener.on_event.call_args_list[1][0][0]
         assert error_event.type == "error"
 
     @pytest.mark.asyncio
@@ -241,9 +241,9 @@ async def test_handle_audio_delta_event_success(self, model):
 
         await model._handle_ws_event(audio_event)
 
-        # Should emit audio event to listeners
-        mock_listener.on_event.assert_called_once()
-        emitted_event = mock_listener.on_event.call_args[0][0]
+        # Should emit raw server event and audio event to listeners
+        assert mock_listener.on_event.call_count == 2
+        emitted_event = mock_listener.on_event.call_args_list[1][0][0]
         assert isinstance(emitted_event, RealtimeModelAudioEvent)
         assert emitted_event.response_id == "resp_123"
         assert emitted_event.data == b"test audio"  # decoded from base64
@@ -274,9 +274,9 @@ async def test_handle_error_event_success(self, model):
 
         await model._handle_ws_event(error_event)
 
-        # Should emit error event to listeners
-        mock_listener.on_event.assert_called_once()
-        emitted_event = mock_listener.on_event.call_args[0][0]
+        # Should emit raw server event and error event to listeners
+        assert mock_listener.on_event.call_count == 2
+        emitted_event = mock_listener.on_event.call_args_list[1][0][0]
         assert isinstance(emitted_event, RealtimeModelErrorEvent)
 
     @pytest.mark.asyncio
@@ -303,12 +303,12 @@ async def test_handle_tool_call_event_success(self, model):
 
         await model._handle_ws_event(tool_call_event)
 
-        # Should emit both item updated and tool call events
-        assert mock_listener.on_event.call_count == 2
+        # Should emit raw server event, item updated, and tool call events
+        assert mock_listener.on_event.call_count == 3
 
-        # First should be item updated, second should be tool call
+        # First should be raw server event, second should be item updated, third should be tool call
         calls = mock_listener.on_event.call_args_list
-        tool_call_emitted = calls[1][0][0]
+        tool_call_emitted = calls[2][0][0]
         assert isinstance(tool_call_emitted, RealtimeModelToolCallEvent)
         assert tool_call_emitted.name == "get_weather"
         assert tool_call_emitted.arguments == '{"location": "San Francisco"}'