fix: Use shared token on underlying stream process

This way, when the stop command is called, the underlying stream process should be signaled to cancel right away too.

Author: carlreid

src/StreamMaster.Streams/Broadcasters/SourceBroadcaster.cs

@@ -106,20 +106,21 @@ public async Task<long> SetSourceStreamAsync(SMStreamInfo SMStreamInfo, Cancella
 
         this.SMStreamInfo = SMStreamInfo;
 
+        // Start a new streaming task
+        _cancellationTokenSource = new CancellationTokenSource();
+
         Stopwatch stopwatch = Stopwatch.StartNew();
         try
         {
             (Stream? stream, int processId, ProxyStreamError? error) =
-                await streamFactory.GetStream(SMStreamInfo, cancellationToken).ConfigureAwait(false);
+                await streamFactory.GetStream(SMStreamInfo, _cancellationTokenSource.Token).ConfigureAwait(false);
             stopwatch.Stop();
             if (stream == null || error != null)
             {
                 logger.LogError("Could not create source stream for channel broadcaster: {Id} {Name} {Error}", SMStreamInfo.Id, SMStreamInfo.Name, error?.Message);
                 return 0;
             }
 
-            // Start a new streaming task
-            _cancellationTokenSource = new CancellationTokenSource();
             _streamingTask = Task.Run(() => RunPipelineAsync(stream, SMStreamInfo.Name, cancellationToken: _cancellationTokenSource.Token), _cancellationTokenSource.Token);
             return stopwatch.ElapsedMilliseconds;
         }
@@ -193,6 +194,11 @@ private async Task RunPipelineAsync(Stream sourceStream, string name, int buffer
                     timeoutCts?.Dispose();
                 }
 
+                if (cancellationToken.IsCancellationRequested)
+                {
+                    break;
+                }
+
                 if (bytesRead == 0)
                 {
                     if (!hasReadData)