@@ -285,11 +285,14 @@ def setup_once() -> None:
         if isinstance(Stream.__dict__.get("_iterator"), cached_property):
             _original_stream_iterator = Stream._iterator.func  # type: ignore[attr-defined]
 
-            def _sentry_patched_stream_iterator(self: "Any") -> "Any":
-                original = _original_stream_iterator(self)
+            def _sentry_patched_stream_iterator(self: "Stream") -> "Any":
+                iterator = _original_stream_iterator(self)
                 if not hasattr(self, "_span"):
-                    return original
-                return _wrap_synchronous_message_iterator(self, original)
+                    return iterator
+
+                return _wrap_synchronous_message_iterator(
+                    cast("_PatchedRawMessageStream", self), iterator
+                )
 
             patched = cached_property(_sentry_patched_stream_iterator)
             patched.__set_name__(Stream, "_iterator")
@@ -298,11 +301,13 @@ def _sentry_patched_stream_iterator(self: "Any") -> "Any":
         if isinstance(AsyncStream.__dict__.get("_iterator"), cached_property):
             _original_async_stream_iterator = AsyncStream._iterator.func  # type: ignore[attr-defined]
 
-            def _sentry_patched_async_stream_iterator(self: "Any") -> "Any":
-                original = _original_async_stream_iterator(self)
+            def _sentry_patched_async_stream_iterator(self: "AsyncStream") -> "Any":
+                iterator = _original_async_stream_iterator(self)
                 if not hasattr(self, "_span"):
-                    return original
-                return _wrap_asynchronous_message_iterator(self, original)
+                    return iterator
+                return _wrap_asynchronous_message_iterator(
+                    cast("_PatchedRawAsyncMessageStream", self), iterator
+                )
 
             patched = cached_property(_sentry_patched_async_stream_iterator)
             patched.__set_name__(AsyncStream, "_iterator")