@@ -157,7 +157,7 @@ def has_room(self, room_id: str) -> bool:
157157 return room_id in self ._rooms_by_id
158158
159159
160- def delete_room (self , room_id : str ) -> None :
160+ def delete_room (self , room_id : str ) -> bool :
161161 """
162162 Gracefully deletes a YRoom given a room ID. This stops the YRoom,
163163 closing all Websockets with close code 1001 (server shutting down),
@@ -169,17 +169,17 @@ def delete_room(self, room_id: str) -> None:
169169 """
170170 yroom = self ._rooms_by_id .pop (room_id , None )
171171 if not yroom :
172- return None
172+ return True
173173
174174 self .log .info (f"Stopping YRoom '{ room_id } '." )
175175 try :
176176 yroom .stop ()
177- return None
177+ return True
178178 except Exception as e :
179179 self .log .exception (
180180 f"Exception raised when stopping YRoom '{ room_id } : "
181181 )
182- return None
182+ return False
183183
184184
185185 async def _watch_rooms (self ) -> None :
@@ -286,10 +286,10 @@ async def stop(self) -> None:
286286 deletion_tasks = []
287287
288288 # Define task that deletes the room and waits until the content is saved
289- async def delete_then_save (room_id : str , room : YRoom ):
290- self .delete_room (room_id )
289+ async def delete_then_save (room_id : str , room : YRoom ) -> bool :
290+ result = self .delete_room (room_id )
291291 await room .until_saved
292- return None
292+ return result
293293
294294 # Delete all rooms concurrently using `delete_then_save()`
295295 for room_id , room in self ._rooms_by_id .items ():
0 commit comments