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

Follow https://nim-lang.org/docs/asyncdispatch.html\#multiple-async-backend-support precisely

Browse source
This commit is contained in:
Zahary Karadjov 2021-12-08 16:59:12 +02:00
commit c653d05f27
No known key found for this signature in database
GPG key ID: C8936F8A3073D609
2 changed files with 11 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

6
faststreams.nimble
View file

@ -23,12 +23,12 @@ proc test(env, path: string) =
let common_args = "-r -f --hints:off --skipParentCfg --styleCheck:usages --styleCheck:error"
exec "nim " & lang & " " & env &
" -d:async_backend=none " & common_args & " " & path
" -d:asyncBackend=none " & common_args & " " & path
exec "nim " & lang & " " & env &
" -d:async_backend=chronos " & common_args & " " & path
" -d:asyncBackend=chronos " & common_args & " " & path
# TODO std backend is broken / untested
# exec "nim " & lang & " " & env &
# " -d:async_backend=chronos " & common_args & " " & path
# " -d:asyncBackend=asyncdispatch " & common_args & " " & path
task test, "Run all tests":
test "-d:debug --threads:on", "tests/all_tests"

16
faststreams/async_backend.nim
View file

@ -1,12 +1,12 @@
const
# To compile with async support, use `-d:async_backend=chronos|asyncdispatch`
async_backend {.strdefine.} = "none"
# To compile with async support, use `-d:asyncBackend=chronos|asyncdispatch`
asyncBackend {.strdefine.} = "none"
const
faststreams_async_backend {.strdefine.} = ""
when faststreams_async_backend != "":
{.fatal: "use `-d:async_backend` instead".}
{.fatal: "use `-d:asyncBackend` instead".}
type
CloseBehavior* = enum
@ -15,11 +15,11 @@ type
const
debugHelpers* = defined(debugHelpers)
fsAsyncSupport* = async_backend != "none"
fsAsyncSupport* = asyncBackend != "none"
when async_backend == "none":
when asyncBackend == "none":
discard
elif async_backend == "chronos":
elif asyncBackend == "chronos":
import
chronos
@ -29,7 +29,7 @@ elif async_backend == "chronos":
template fsAwait*(f: Future): untyped =
await f
elif async_backend in ["std", "asyncdispatch"]:
elif asyncBackend == "asyncdispatch":
import
std/asyncdispatch
@ -47,7 +47,7 @@ elif async_backend in ["std", "asyncdispatch"]:
type Duration* = int
else:
{.fatal: "Unrecognized network backend: " & async_backend.}
{.fatal: "Unrecognized network backend: " & asyncBackend .}
when defined(danger):
template fsAssert*(x) = discard