@router.websocket("/subscribe/some/data/changes")asyncdefsubscribe_connectors_status(websocket:WebSocket,)->None:asyncdefsend_some_data()->None:last_data=awaitget_data()awaitwebsocket.send_json({"data":last_data})whileTrue:awaitasyncio.sleep(1)new_data=awaitget_data()ifnew_data!=last_data:# This happens very rarely that's why I would like to close all of these unused tasks.last_data=new_dataawaitwebsocket.send_json({"foo":last_data})asyncdefwatch_status()->None:whilewebsocket.client_state==WebSocketState.CONNECTED:# We are not expecting any data, but this will change to the client state if the connection will be closed.awaitwebsocket.receive()tg.cancel_scope.cancel()awaitwebsocket.accept()asyncwithcreate_task_group()astg:tg.start_soon(watch_status)tg.start_soon(send_some_data)

@@            Coverage Diff            @@##            master     #4376   +/-   ##=========================================  Coverage   100.00%   100.00%           =========================================  Files          535       535             Lines        13825     13826    +1     =========================================+ Hits         13825     13826    +1