Skip to content

Commit 02d1bf7

Browse files
committed
fix
1 parent 36fd9bd commit 02d1bf7

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

src/a2a/server/routes/jsonrpc_dispatcher.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -383,7 +383,7 @@ async def _process_streaming_request(
383383
first_event = None
384384

385385
async def _wrap_stream(
386-
st: AsyncGenerator, event: Any | None
386+
st: AsyncGenerator, first_evt: Any | None
387387
) -> AsyncGenerator[dict[str, Any], None]:
388388
def _map_event(evt: Any) -> dict[str, Any]:
389389
stream_response = proto_utils.to_stream_response(evt)
@@ -393,8 +393,8 @@ def _map_event(evt: Any) -> dict[str, Any]:
393393
return JSONRPC20Response(result=result, _id=request_id).data
394394

395395
try:
396-
if event is not None:
397-
yield _map_event(event)
396+
if first_evt is not None:
397+
yield _map_event(first_evt)
398398

399399
async for event in st:
400400
yield _map_event(event)

0 commit comments

Comments
 (0)