File tree Expand file tree Collapse file tree 1 file changed +11
-12
lines changed Expand file tree Collapse file tree 1 file changed +11
-12
lines changed Original file line number Diff line number Diff line change @@ -615,18 +615,17 @@ async def get_sse_server_app(
615615 sse = RouterSseTransport ("/messages/" , api_key = api_key )
616616
617617 async def handle_sse (request : Request ) -> Response :
618- async def app (scope : Scope , receive : Receive , send : Send ) -> None :
619- async with sse .connect_sse (
620- scope ,
621- receive ,
622- send ,
623- ) as (read_stream , write_stream ):
624- await self .aggregated_server .run (
625- read_stream ,
626- write_stream ,
627- self .aggregated_server .initialization_options ,
628- )
629- return app
618+ async with sse .connect_sse (
619+ scope ,
620+ receive ,
621+ send ,
622+ ) as (read_stream , write_stream ):
623+ await self .aggregated_server .run (
624+ read_stream ,
625+ write_stream ,
626+ self .aggregated_server .initialization_options ,
627+ )
628+ return Response ()
630629
631630 lifespan_handler : t .Optional [Lifespan [Starlette ]] = None
632631 if include_lifespan :
You can’t perform that action at this time.
0 commit comments