diff --git a/src/anthropic/_streaming.py b/src/anthropic/_streaming.py
index bfb3e821..2062fb28 100644
--- a/src/anthropic/_streaming.py
+++ b/src/anthropic/_streaming.py
@@ -85,7 +85,7 @@ def __stream__(self) -> Iterator[_T]:
                 if sse.event == "completion":
                     yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-                if (
+                elif (
                     sse.event == "message_start"
                     or sse.event == "message_delta"
                     or sse.event == "message_stop"
@@ -100,10 +100,10 @@ def __stream__(self) -> Iterator[_T]:
 
                     yield process_data(data=data, cast_to=cast_to, response=response)
 
-                if sse.event == "ping":
+                elif sse.event == "ping":
                     continue
 
-                if sse.event == "error":
+                elif sse.event == "error":
                     body = sse.data
 
                     try:
@@ -206,7 +206,7 @@ async def __stream__(self) -> AsyncIterator[_T]:
                 if sse.event == "completion":
                     yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-                if (
+                elif (
                     sse.event == "message_start"
                     or sse.event == "message_delta"
                     or sse.event == "message_stop"
@@ -221,10 +221,10 @@ async def __stream__(self) -> AsyncIterator[_T]:
 
                     yield process_data(data=data, cast_to=cast_to, response=response)
 
-                if sse.event == "ping":
+                elif sse.event == "ping":
                     continue
 
-                if sse.event == "error":
+                elif sse.event == "error":
                     body = sse.data
 
                     try: