diff --git a/FFMpegCore.Test/VideoTest.cs b/FFMpegCore.Test/VideoTest.cs index 644476f..9285433 100644 --- a/FFMpegCore.Test/VideoTest.cs +++ b/FFMpegCore.Test/VideoTest.cs @@ -643,7 +643,7 @@ public async Task Video_Cancel_Async() { await using var resStream = new MemoryStream(); var reader = new StreamPipeDataReader(resStream); - var writer = new RawVideoPipeDataWriter(BitmapSource.CreateBitmaps(256, System.Drawing.Imaging.PixelFormat.Format24bppRgb, 128, 128)); + var writer = new RawVideoPipeDataWriter(BitmapSource.CreateBitmaps(512, System.Drawing.Imaging.PixelFormat.Format24bppRgb, 128, 128)); var task = FFMpegArguments .FromPipe(writer) @@ -653,7 +653,7 @@ public async Task Video_Cancel_Async() .CancellableThrough(out var cancel) .ProcessAsynchronously(false); - await Task.Delay(100); + await Task.Delay(300); cancel(); var result = await task; diff --git a/FFMpegCore/FFMpeg/FFMpegArgumentProcessor.cs b/FFMpegCore/FFMpeg/FFMpegArgumentProcessor.cs index c6f74ac..bdd6ea5 100644 --- a/FFMpegCore/FFMpeg/FFMpegArgumentProcessor.cs +++ b/FFMpegCore/FFMpeg/FFMpegArgumentProcessor.cs @@ -26,7 +26,7 @@ internal FFMpegArgumentProcessor(FFMpegArguments ffMpegArguments) public string Arguments => _ffMpegArguments.Text; - private event EventHandler _cancelEvent; + private event EventHandler CancelEvent = null!; public FFMpegArgumentProcessor NotifyOnProgress(Action onPercentageProgress, TimeSpan totalTimeSpan) { @@ -41,7 +41,7 @@ public FFMpegArgumentProcessor NotifyOnProgress(Action onTimeProgress) } public FFMpegArgumentProcessor CancellableThrough(out Action cancel) { - cancel = () => _cancelEvent?.Invoke(this, EventArgs.Empty); + cancel = () => CancelEvent?.Invoke(this, EventArgs.Empty); return this; } public bool ProcessSynchronously(bool throwOnError = true) @@ -53,7 +53,7 @@ void OnCancelEvent(object sender, EventArgs args) instance?.SendInput("q"); cancellationTokenSource.Cancel(); } - _cancelEvent += OnCancelEvent; + CancelEvent += OnCancelEvent; _ffMpegArguments.Pre(); try @@ -70,7 +70,7 @@ void OnCancelEvent(object sender, EventArgs args) } finally { - _cancelEvent -= OnCancelEvent; + CancelEvent -= OnCancelEvent; _ffMpegArguments.Post(); } @@ -92,7 +92,7 @@ void OnCancelEvent(object sender, EventArgs args) instance?.SendInput("q"); cancellationTokenSource.Cancel(); } - _cancelEvent += OnCancelEvent; + CancelEvent += OnCancelEvent; _ffMpegArguments.Pre(); try @@ -109,7 +109,7 @@ await Task.WhenAll(instance.FinishedRunning().ContinueWith(t => } finally { - _cancelEvent -= OnCancelEvent; + CancelEvent -= OnCancelEvent; _ffMpegArguments.Post(); }