Merge 36d778a3a2 into 1c4333ee4c

Bump Instances

FFMpegCore/FFMpeg/Arguments/InputExistingPipeArgument.cs

@@ -0,0 +1,46 @@
+using System.Diagnostics;
+using FFMpegCore.Pipes;
+
+namespace FFMpegCore.Arguments
+{
+    /// <summary>
+    /// Represents input parameter for a specific name pipe
+    /// </summary>
+    public class InputExistingPipeArgument : IInputArgument
+    {
+        public string PipeName { get; }
+        public string PipePath => PipeHelpers.GetPipePath(PipeName);
+        public string Text => $"-i \"{PipePath}\"";
+
+        public InputExistingPipeArgument(string pipeName)
+        {
+            PipeName = pipeName;
+        }
+
+        public void Pre()
+        {
+            if (string.IsNullOrEmpty(PipeName))
+            {
+                throw new InvalidOperationException("Pipe name cannot be null or empty");
+            }
+        }
+
+        public async Task During(CancellationToken cancellationToken = default)
+        {
+            try
+            {
+                var tcs = new TaskCompletionSource<bool>();
+                cancellationToken.Register(() => tcs.TrySetCanceled());
+                await tcs.Task;
+            }
+            catch(OperationCanceledException)
+            {
+                Debug.WriteLine($"{GetType().Name} cancelled");
+            }
+        }
+
+        public void Post()
+        {
+        }
+    }
+}

FFMpegCore/FFMpeg/FFMpegArguments.cs

@@ -26,6 +26,7 @@ private string GetText()
         public static FFMpegArguments FromUrlInput(Uri uri, Action<FFMpegArgumentOptions>? addArguments = null) => new FFMpegArguments().WithInput(new InputArgument(uri.AbsoluteUri, false), addArguments);
         public static FFMpegArguments FromDeviceInput(string device, Action<FFMpegArgumentOptions>? addArguments = null) => new FFMpegArguments().WithInput(new InputDeviceArgument(device), addArguments);
         public static FFMpegArguments FromPipeInput(IPipeSource sourcePipe, Action<FFMpegArgumentOptions>? addArguments = null) => new FFMpegArguments().WithInput(new InputPipeArgument(sourcePipe), addArguments);
+        public static FFMpegArguments FromPipeInput(string pipeName, Action<FFMpegArgumentOptions>? addArguments = null) => new FFMpegArguments().WithInput(new InputExistingPipeArgument(pipeName), addArguments);
 
         public FFMpegArguments WithGlobalOptions(Action<FFMpegGlobalArguments> configureOptions)
         {
@@ -41,6 +42,7 @@ public FFMpegArguments WithGlobalOptions(Action<FFMpegGlobalArguments> configure
         public FFMpegArguments AddUrlInput(Uri uri, Action<FFMpegArgumentOptions>? addArguments = null) => WithInput(new InputArgument(uri.AbsoluteUri, false), addArguments);
         public FFMpegArguments AddDeviceInput(string device, Action<FFMpegArgumentOptions>? addArguments = null) => WithInput(new InputDeviceArgument(device), addArguments);
         public FFMpegArguments AddPipeInput(IPipeSource sourcePipe, Action<FFMpegArgumentOptions>? addArguments = null) => WithInput(new InputPipeArgument(sourcePipe), addArguments);
+        public FFMpegArguments AddPipeInput(string pipeName, Action<FFMpegArgumentOptions>? addArguments = null) => WithInput(new InputExistingPipeArgument(pipeName), addArguments);
         public FFMpegArguments AddMetaData(string content, Action<FFMpegArgumentOptions>? addArguments = null) => WithInput(new MetaDataArgument(content), addArguments);
         public FFMpegArguments AddMetaData(IReadOnlyMetaData metaData, Action<FFMpegArgumentOptions>? addArguments = null) => WithInput(new MetaDataArgument(MetaDataSerializer.Instance.Serialize(metaData)), addArguments);
 

FFMpegCore/FFMpegCore.csproj

@@ -17,10 +17,8 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Instances" Version="3.0.0" />
+    <PackageReference Include="Instances" Version="3.0.1" />
     <PackageReference Include="System.Text.Json" Version="9.0.0" />
   </ItemGroup>
 
-  
-
 </Project>