1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
import asyncdispatch, asyncnet
var port: Port
proc createServer() {.async.} =
var server = newAsyncSocket()
server.setSockOpt(OptReuseAddr, true)
bindAddr(server)
port = getLocalAddr(server)[1]
server.listen()
while true:
let client = await server.accept()
discard await client.recvLine()
asyncCheck createServer()
var done = false
proc f(): Future[void] {.async.} =
let s = createAsyncNativeSocket()
await s.connect("localhost", port)
await s.send("123")
done = true
waitFor f()
doAssert done
|
