diff --git a/docs/docs/tutorials/streaming/index.md b/docs/docs/tutorials/streaming/index.md
index 8782424d45..a0cedb092d 100644
--- a/docs/docs/tutorials/streaming/index.md
+++ b/docs/docs/tutorials/streaming/index.md
@@ -84,12 +84,13 @@ import asyncio
 async def read_output_stream():
   output_stream = stream_predict(question="Why did a chicken cross the kitchen?")
 
+  return_value = None
   async for chunk in output_stream:
-    return_value = None
     if isinstance(chunk, dspy.streaming.StreamResponse):
       print(f"Output token of field {chunk.signature_field_name}: {chunk.chunk}")
     elif isinstance(chunk, dspy.Prediction):
       return_value = chunk
+  return return_value
 
 
 program_output = asyncio.run(read_output_stream())