mirror of
https://github.com/fastogt/fastocloud_admin.git
synced 2025-03-09 23:38:52 +00:00
Check remove
This commit is contained in:
parent
6ba03c71d9
commit
c3b15c2102
1 changed files with 1 additions and 3 deletions
|
@ -252,17 +252,15 @@ class Service(IStreamHandler):
|
||||||
stream.save()
|
stream.save()
|
||||||
|
|
||||||
def remove_stream(self, sid: str):
|
def remove_stream(self, sid: str):
|
||||||
for stream in self._streams:
|
for stream in list(self._streams):
|
||||||
if stream.id == ObjectId(sid):
|
if stream.id == ObjectId(sid):
|
||||||
self._client.stop_stream(sid)
|
self._client.stop_stream(sid)
|
||||||
self._streams.remove(stream)
|
self._streams.remove(stream)
|
||||||
safe_delete_stream(stream)
|
|
||||||
self._settings.remove_stream(stream) #
|
self._settings.remove_stream(stream) #
|
||||||
|
|
||||||
def remove_all_streams(self):
|
def remove_all_streams(self):
|
||||||
for stream in self._streams:
|
for stream in self._streams:
|
||||||
self._client.stop_stream(stream.get_id())
|
self._client.stop_stream(stream.get_id())
|
||||||
safe_delete_stream(stream)
|
|
||||||
self._streams = []
|
self._streams = []
|
||||||
self._settings.remove_all_streams() #
|
self._settings.remove_all_streams() #
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue