mirror of
https://github.com/nim-lang/Nim.git
synced 2025-12-28 08:54:53 +00:00
10142e4a80
This also fixes a compilation error in modules, based only on the new async module (i.e. not importing the full asyncdispatch)
41 lines
854 B
Nim
41 lines
854 B
Nim
discard """
|
|
output: "1\nmessa"
|
|
"""
|
|
|
|
import async
|
|
|
|
# bug #2377
|
|
proc test[T](v: T) {.async.} =
|
|
echo $v
|
|
|
|
asyncCheck test[int](1)
|
|
|
|
# More complex case involving typedesc and static params
|
|
type
|
|
SomeMsg = object
|
|
data: string
|
|
|
|
template msgId(M: type SomeMsg): int = 1
|
|
|
|
proc recvMsg(): Future[tuple[msgId: int, msgData: string]] {.async.} =
|
|
return (1, "message")
|
|
|
|
proc read(data: string, T: type SomeMsg, maxBytes: int): T =
|
|
result.data = data[0 ..< min(data.len, maxBytes)]
|
|
|
|
proc nextMsg*(MsgType: typedesc,
|
|
maxBytes: static[int]): Future[MsgType] {.async.} =
|
|
const wantedId = MsgType.msgId
|
|
|
|
while true:
|
|
var (nextMsgId, nextMsgData) = await recvMsg()
|
|
if nextMsgId == wantedId:
|
|
return nextMsgData.read(MsgType, maxBytes)
|
|
|
|
proc main {.async.} =
|
|
let msg = await nextMsg(SomeMsg, 5)
|
|
echo msg.data
|
|
|
|
asyncCheck main()
|
|
|