Fix ffmpeg link to same stream

2023-01-13 13:36:43 +03:00
parent 09fefca712
commit ba0c7d911d
1 changed files with 2 additions and 1 deletions
@@ -102,9 +102,10 @@ func (s *Stream) AddConsumer(cons streamer.Consumer) (err error) {
 	}

 	s.wg.Done()
-	s.wg.Wait()

 	if len(producers) == 0 {
+		s.wg.Wait()
+
 		s.stopProducers()

 		if len(codecs) > 0 {