Skip to content

Commit

Permalink
[71-74] FileSinkSpec (#6619)
Browse files Browse the repository at this point in the history
* [71-74] `FileSinkSpec`

* Revert "[71-74] `FileSinkSpec`"

This reverts commit 6ef392b.

* fix

---------

Co-authored-by: Aaron Stannard <aaron@petabridge.com>
  • Loading branch information
eaba and Aaronontheweb authored Mar 28, 2023
1 parent af943a9 commit 485a7c4
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/core/Akka.Streams.Tests/IO/FileSinkSpec.cs
Original file line number Diff line number Diff line change
Expand Up @@ -408,9 +408,9 @@ await AwaitAssertAsync(() =>
}

[Fact]
public void SynchronousFileSink_should_write_buffered_element_if_manual_flush_is_called()
public async Task SynchronousFileSink_should_write_buffered_element_if_manual_flush_is_called()
{
this.AssertAllStagesStopped(async() =>
await this.AssertAllStagesStoppedAsync(async() =>
{
await TargetFileAsync(async f =>
{
Expand Down Expand Up @@ -468,7 +468,7 @@ private async Task TargetFileAsync(
{
// this is the proverbial stream kill switch, make sure that all streams
// are dead so that the file handle would be released
await this.AssertAllStagesStoppedAsync(async() => { }, materializer);
await this.AssertAllStagesStoppedAsync(() => { return Task.CompletedTask; }, materializer);

//give the system enough time to shutdown and release the file handle
await Task.Delay(500);
Expand Down

0 comments on commit 485a7c4

Please sign in to comment.