File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -123,7 +123,7 @@ def setup_once() -> None:
123123
124124 # Before https://github.com/anthropics/anthropic-sdk-python/commit/b1a1c0354a9aca450a7d512fdbdeb59c0ead688a
125125 # MessageStream inherits from Stream, so patching Stream is sufficient on these versions.
126- if version is not None and version >= ( 0 , 26 , 2 ):
126+ if not issubclass ( MessageStream , Stream ):
127127 MessageStream .__iter__ = _wrap_message_stream_iter (MessageStream .__iter__ )
128128 MessageStream .__next__ = _wrap_message_stream_next (MessageStream .__next__ )
129129 MessageStream .close = _wrap_message_stream_close (MessageStream .close )
@@ -786,8 +786,7 @@ def _wrap_stream_iter(
786786
787787 def __iter__ (self : "Stream" ) -> "Iterator[RawMessageStreamEvent]" :
788788 if not hasattr (self , "_span" ):
789- for event in f (self ):
790- yield event
789+ yield from f (self )
791790 return
792791
793792 _initialize_data_accumulation_state (self )
@@ -988,8 +987,7 @@ def _wrap_message_stream_iter(
988987
989988 def __iter__ (self : "MessageStream" ) -> "Iterator[MessageStreamEvent]" :
990989 if not hasattr (self , "_span" ):
991- for event in f (self ):
992- yield event
990+ yield from f (self )
993991 return
994992
995993 _initialize_data_accumulation_state (self )
You can’t perform that action at this time.
0 commit comments