jyapayne/nim-faststreams
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

allowAsyncOps applies to async file flushing as well

Browse source
This commit is contained in:
Zahary Karadjov 2022-01-20 18:39:31 +02:00
commit 02d120b7f6
2 changed files with 9 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
faststreams/outputs.nim
View file

@ -273,6 +273,14 @@ let fileOutputVTable = OutputStreamVTable(
{.nimcall, gcsafe, raises: [IOError, Defect].} = {.nimcall, gcsafe, raises: [IOError, Defect].} =
flushFile FileOutputStream(s).file flushFile FileOutputStream(s).file
, ,
flushAsync: proc (s: OutputStream): Future[void]
{.nimcall, gcsafe, raises: [IOError, Defect].} =
fsAssert FileOutputStream(s).allowAsyncOps
flushFile FileOutputStream(s).file
result = newFuture[void]()
fsTranslateErrors "Unexpected exception from merely completing a future":
result.complete()
,
closeSync: proc (s: OutputStream) closeSync: proc (s: OutputStream)
{.nimcall, gcsafe, raises: [IOError, Defect].} = {.nimcall, gcsafe, raises: [IOError, Defect].} =
close FileOutputStream(s).file close FileOutputStream(s).file

2
faststreams/pipelines.nim
View file

@ -127,7 +127,7 @@ when fsAsyncSupport:
flush destination flush destination
, ,
flushAsync: proc (s: OutputStream): Future[void] flushAsync: proc (s: OutputStream): Future[void]
{.nimcall, gcsafe, raises: [IOError, Defect].} = {.nimcall, gcsafe, raises: [IOError, Defect].} =
fsTranslateErrors "Unexpected error from the async macro": fsTranslateErrors "Unexpected error from the async macro":
let destination = LayeredOutputStream(s).destination let destination = LayeredOutputStream(s).destination
if destination != nil: if destination != nil: