if time.time()-lasttime>timeout:
to_stop.add(stream)
for stream in to_stop:
- self.stopBroadcast(stream)
+ try:
+ self.stopBroadcast(stream)
+ except:
+ pass
self._resultlock.release()
+ def check_stream(self,stream_name):
+ if stream_name in self.streams:
+ self.streams[stream_name]=time.time()
+ return True
+ else:
+ return False
+
def pauseBroadcast(self, stream_name):
return self._write(VlcMessage.request.pauseBroadcast(stream_name))