File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -84,8 +84,7 @@ async def _remove_stream_writer(self, session_id: UUID) -> None:
8484 Remove the SSE session with the given session ID.
8585 """
8686 logger .debug (f"Remove SSE session with ID: { session_id } " )
87- writer = self ._read_stream_writers .pop (session_id , None )
88- if writer :
87+ if writer := self ._read_stream_writers .pop (session_id , None ):
8988 await writer .aclose ()
9089 logger .debug (f"Closed SSE session with ID: { session_id } " )
9190 else :
@@ -132,10 +131,12 @@ async def sse_writer():
132131 ),
133132 }
134133 )
134+
135135 background_task = BackgroundTask (self ._remove_stream_writer , session_id )
136136 async with anyio .create_task_group () as tg :
137137 response = EventSourceResponse (
138- content = sse_stream_reader , data_sender_callable = sse_writer ,
138+ content = sse_stream_reader ,
139+ data_sender_callable = sse_writer ,
139140 background = background_task ,
140141 )
141142 logger .debug ("Starting SSE response task" )
You can’t perform that action at this time.
0 commit comments