mirror of
https://github.com/waku-org/nwaku.git
synced 2025-01-15 17:35:45 +00:00
36 lines
1.0 KiB
Nim
36 lines
1.0 KiB
Nim
import
|
|
stew/shims/macros,
|
|
async_backend, inputs, outputs
|
|
|
|
export
|
|
async_backend
|
|
|
|
macro fsMultiSync*(body: untyped) =
|
|
# We will produce an identical copy of the annotated proc,
|
|
# but taking async parameters and having the async pragma.
|
|
var
|
|
asyncProcBody = copy body
|
|
asyncProcParams = asyncProcBody[3]
|
|
|
|
asyncProcBody.addPragma(bindSym"async")
|
|
|
|
# The return types becomes Future[T]
|
|
if asyncProcParams[0].kind == nnkEmpty:
|
|
asyncProcParams[0] = newTree(nnkBracketExpr, bindSym"Future", ident"void")
|
|
else:
|
|
asyncProcParams[0] = newTree(nnkBracketExpr, bindSym"Future", asyncProcParams[0])
|
|
|
|
# We replace all stream inputs with their async counterparts
|
|
for i in 1 ..< asyncProcParams.len:
|
|
let paramsDef = asyncProcParams[i]
|
|
let typ = paramsDef[^2]
|
|
if eqIdent(typ, "InputStream"):
|
|
paramsDef[^2] = bindSym "AsyncInputStream"
|
|
elif eqIdent(typ, "OutputStream"):
|
|
paramsDef[^2] = bindSym "AsyncOutputStream"
|
|
|
|
result = newStmtList(body, asyncProcBody)
|
|
when defined(debugSupportAsync):
|
|
echo result.repr
|
|
|