Fail FileSubscriber's Task if it can't open the file

akkadotnet · May 25, 2021 · 03338fa · 03338fa
1 parent 6e53684
commit 03338fa
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/src/core/Akka.Streams.Tests/IO/FileSinkSpec.cs b/src/core/Akka.Streams.Tests/IO/FileSinkSpec.cs
@@ -348,6 +348,18 @@ public void SynchronousFileSink_should_complete_materialized_task_with_an_except
             }, _materializer);
         }
 
+        [Fact]
+        public void SynchronousFileSink_should_complete_with_failure_when_file_cannot_be_open()
+        {
+            TargetFile(f =>
+            {
+                var completion = Source.Single(ByteString.FromString("42"))
+                    .RunWith(FileIO.ToFile(new FileInfo("I-hope-this-file-doesnt-exist.txt"), FileMode.Open), _materializer);
+
+                AssertThrows<FileNotFoundException>(completion.Wait);
+            }, _materializer);
+        }
+
         [Fact]
         public void SynchronousFileSink_should_write_each_element_if_auto_flush_is_set()
         {

diff --git a/src/core/Akka.Streams/Implementation/IO/FileSubscriber.cs b/src/core/Akka.Streams/Implementation/IO/FileSubscriber.cs
@@ -111,7 +111,7 @@ protected override void PreStart()
             }
             catch (Exception ex)
             {
-                CloseAndComplete(IOResult.Failed(_bytesWritten, ex));
+                CloseAndComplete(new Try<IOResult>(ex));
                 Cancel();
             }
         }