chore(internal): remove unused __events stream property

anthropics · May 24, 2024 · 472b831 · 472b831
1 parent 196e4b0
commit 472b831
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/src/anthropic/lib/streaming/_messages.py b/src/anthropic/lib/streaming/_messages.py
@@ -37,7 +37,6 @@ def __init__(
 
         self.text_stream = self.__stream_text__()
         self.__final_message_snapshot: Message | None = None
-        self.__events: list[MessageStreamEvent] = []
 
     def get_final_message(self) -> Message:
         """Waits until the stream has been read to completion and returns
@@ -123,8 +122,6 @@ def on_timeout(self) -> None:
     def __stream__(self) -> Iterator[MessageStreamEvent]:
         try:
             for event in super().__stream__():
-                self.__events.append(event)
-
                 self.__final_message_snapshot = accumulate_event(
                     event=event,
                     current_snapshot=self.__final_message_snapshot,
@@ -227,7 +224,6 @@ def __init__(
 
         self.text_stream = self.__stream_text__()
         self.__final_message_snapshot: Message | None = None
-        self.__events: list[MessageStreamEvent] = []
 
     async def get_final_message(self) -> Message:
         """Waits until the stream has been read to completion and returns
@@ -319,8 +315,6 @@ async def on_timeout(self) -> None:
     async def __stream__(self) -> AsyncIterator[MessageStreamEvent]:
         try:
             async for event in super().__stream__():
-                self.__events.append(event)
-
                 self.__final_message_snapshot = accumulate_event(
                     event=event,
                     current_snapshot=self.__final_message_snapshot,