Fix stream pipeline chaining

Author: saddam213

TensorStack.Common/Video/VideoStream.cs

@@ -1,11 +1,12 @@
 // Copyright (c) TensorStack. All rights reserved.
 // Licensed under the Apache 2.0 License.
+using System.Collections.Generic;
 using TensorStack.Common.Video;
 
 namespace TensorStack.Extractors.Common
 {
     public record ExtractorStreamOptions : ExtractorOptions
     {
-        public VideoStream Stream { get; }
+        public IAsyncEnumerable<VideoFrame> Stream { get; }
     }
 }

TensorStack.Extractors/Common/ExtractorStreamOptions.cs

@@ -1,5 +1,6 @@
 // Copyright (c) TensorStack. All rights reserved.
 // Licensed under the Apache 2.0 License.
+using System.Collections.Generic;
 using TensorStack.Common;
 using TensorStack.Common.Pipeline;
 using TensorStack.Common.Tensor;
@@ -64,6 +65,6 @@ public sealed record UpscaleStreamOptions : UpscaleOptions
         /// <summary>
         /// Gets the stream input.
         /// </summary>
-        public VideoStream Stream { get; init; }
+        public IAsyncEnumerable<VideoFrame> Stream { get; init; }
     }
 }

TensorStack.Upscaler/Common/UpscaleOptions.cs

@@ -153,6 +153,7 @@ You can use the TensorStack.Audio package to restore audio from the source video
 ```
 ---
 
+
 ## Tiling Support
 Tiling allows images and video frames to be processed in smaller sections (tiles) instead of all at once. This helps reduce memory usage and can improve performance when working with very large images or high-resolution videos.
 
@@ -182,4 +183,57 @@ Here is a list of some known and tested models compatible with `TensorStack.Upsc
 - [Xenova/swin2SR-classical-sr-x2-64](https://huggingface.co/Xenova/swin2SR-classical-sr-x2-64)  
 - [Xenova/swin2SR-classical-sr-x4-64](https://huggingface.co/Xenova/swin2SR-classical-sr-x4-64)  
 - [Neus/GFPGANv1.4](https://huggingface.co/Neus/GFPGANv1.4)  
-- [TensorStack/Upscale-amuse](https://huggingface.co/TensorStack/Upscale-amuse)  
+- [TensorStack/Upscale-amuse](https://huggingface.co/TensorStack/Upscale-amuse)  
+
+---
+
+## Combining Pipelines
+TensorStack supports chaining multiple pipelines together using `IAsyncEnumerable` streams.  
+This allows complex video processing workflows—such as upscaling and frame interpolation—to be executed efficiently in a **single pass** without storing intermediate results in memory.
+
+In the following example, the video is upscaled by **4×** and its frame rate is increased by **3×**:
+```csharp
+[nuget: TensorStack.Upscaler]
+[nuget: TensorStack.Providers.DML]
+[nuget: TensorStack.Video.Windows]
+
+// Create Provider
+var provider = Provider.GetProvider();
+
+// Upscaler Config
+var upscaleConfig = new UpscalerConfig
+{
+    ScaleFactor = 4,
+    ExecutionProvider = provider,
+    Normalization = Normalization.ZeroToOne,
+    Path = @"M:\Models\RealESR-General-4x\model.onnx"
+}
+
+// Create Pipelines
+using (var upscalePipeline = UpscalePipeline.Create(upscaleConfig))
+using (var interpolationPipeline = InterpolationPipeline.Create(provider))
+{
+    // Read Stream  [512 x 512 @ 8fps]
+    var videoInput = new VideoInputStream("Input.mp4"); 
+    var videoStream = videoInput.GetAsync();
+
+    // Upscale Stream
+    videoStream = upscalePipeline.RunAsync(new UpscaleStreamOptions
+    {
+        Stream = videoStream
+    });
+
+    // Interpolate Stream
+    videoStream = interpolationPipeline.RunAsync(new InterpolationStreamOptions
+    {
+        Multiplier = 3,
+        Stream = videoStream,
+        FrameRate = videoInput.FrameRate,
+        FrameCount = videoInput.FrameCount
+    });
+
+    // Save Steam  [2048 x 2048 @ 24fps]
+    await videoStream.SaveAync("Output.mp4");
+}
+
+```

TensorStack.Upscaler/README.md

@@ -39,10 +39,9 @@ private VideoInputStream(VideoInfo videoInfo)
         /// <param name="frameRateOverride">The frame rate.</param>
         /// <param name="cancellationToken">The cancellation token that can be used by other objects or threads to receive notice of cancellation.</param>
         /// <returns>IAsyncEnumerable&lt;ImageFrame&gt;.</returns>
-        public VideoStream GetAsync(int? widthOverride = default, int? heightOverride = default, float? frameRateOverride = default, ResizeMode resizeMode = ResizeMode.Stretch, CancellationToken cancellationToken = default)
+        public IAsyncEnumerable<VideoFrame> GetAsync(int? widthOverride = default, int? heightOverride = default, float? frameRateOverride = default, ResizeMode resizeMode = ResizeMode.Stretch, CancellationToken cancellationToken = default)
         {
-            var stream = VideoManager.ReadStreamAsync(SourceFile, frameRateOverride, widthOverride, heightOverride, resizeMode, cancellationToken);
-            return new VideoStream(stream, FrameCount, frameRateOverride ?? FrameRate, widthOverride ?? Width, heightOverride ?? Height);
+            return VideoManager.ReadStreamAsync(SourceFile, frameRateOverride, widthOverride, heightOverride, resizeMode, cancellationToken);
         }
 
 

TensorStack.Video.Windows/VideoInputStream.cs

@@ -1,4 +1,5 @@
-using TensorStack.Common.Pipeline;
+using System.Collections.Generic;
+using TensorStack.Common.Pipeline;
 using TensorStack.Common.Tensor;
 using TensorStack.Common.Video;
 
@@ -29,6 +30,8 @@ public sealed record InterpolationVideoOptions : InterpolationOptions
     /// </summary>
     public sealed record InterpolationStreamOptions : InterpolationOptions
     {
-        public VideoStream Stream { get; init; }
+        public int FrameCount { get; init; }
+        public float FrameRate { get; init; }
+        public IAsyncEnumerable<VideoFrame> Stream { get; init; }
     }
 }

TensorStack.Video/Common/InterpolationOptions.cs

@@ -102,11 +102,11 @@ public async Task<VideoTensor> RunAsync(InterpolationVideoOptions options, IProg
         public async IAsyncEnumerable<VideoFrame> RunAsync(InterpolationStreamOptions options, IProgress<RunProgress> progressCallback = default, [EnumeratorCancellation] CancellationToken cancellationToken = default)
         {
             var frameIndex = 0;
-            var totalFrames = options.Stream.FrameCount * options.Multiplier;
-            var newFrameRate = options.Stream.FrameRate * options.Multiplier;
+            var totalFrames = options.FrameCount * options.Multiplier;
+            var newFrameRate = options.FrameRate * options.Multiplier;
 
             var previousFrame = default(ImageTensor);
-            var extraFramePositions = GetFlowEstimationKeyFrames(options.Stream.FrameCount, options.Multiplier);
+            var extraFramePositions = GetFlowEstimationKeyFrames(options.FrameCount, options.Multiplier);
             await foreach (var frame in options.Stream)
             {
                 var currentFrame = frame.Frame.CloneAs();