From 9c26f35c7632503b59763eb1c4b14197c18d7b2d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Miroslav=20=C5=A0ediv=C3=BD?= <sedivy.miro@gmail.com>
Date: Fri, 13 Nov 2020 21:23:48 +0100
Subject: [PATCH] destroy pipelines func.

---
 internal/capture/manager.go | 27 +++++++++++++++------------
 1 file changed, 15 insertions(+), 12 deletions(-)

diff --git a/internal/capture/manager.go b/internal/capture/manager.go
index ce14a76d..0609845c 100644
--- a/internal/capture/manager.go
+++ b/internal/capture/manager.go
@@ -43,10 +43,7 @@ func (manager *CaptureManagerCtx) Start() {
 	manager.StartBroadcastPipeline()
 
 	manager.desktop.OnBeforeScreenSizeChange(func() {
-		manager.video_emit_stop <- true
-		manager.logger.Info().Msgf("stopping video pipeline")
-		manager.video.Stop()
-
+		manager.destroyVideoPipeline()
 		manager.StopBroadcastPipeline()
 	})
 
@@ -93,14 +90,8 @@ func (manager *CaptureManagerCtx) StartStream() {
 func (manager *CaptureManagerCtx) StopStream() {
 	manager.logger.Info().Msgf("stopping pipelines")
 
-	manager.audio_emit_stop <- true
-	manager.logger.Info().Msgf("stopping video pipeline")
-	manager.audio.Stop()
-
-	manager.video_emit_stop <- true
-	manager.logger.Info().Msgf("stopping audio pipeline")
-	manager.video.Stop()
-
+	manager.destroyVideoPipeline()
+	manager.destroyAudioPipeline()
 	manager.streaming = false
 }
 
@@ -148,6 +139,12 @@ func (manager *CaptureManagerCtx) createVideoPipeline() {
 	}()
 }
 
+func (manager *CaptureManagerCtx) destroyVideoPipeline() {
+	manager.video_emit_stop <- true
+	manager.logger.Info().Msgf("stopping video pipeline")
+	manager.video.Stop()
+}
+
 func (manager *CaptureManagerCtx) createAudioPipeline() {
 	var err error
 
@@ -187,3 +184,9 @@ func (manager *CaptureManagerCtx) createAudioPipeline() {
 		}
 	}()
 }
+
+func (manager *CaptureManagerCtx) destroyAudioPipeline() {
+	manager.audio_emit_stop <- true
+	manager.logger.Info().Msgf("stopping audio pipeline")
+	manager.audio.Stop()
+}