blob: 29873a9054f46b48ac3a3099756cb956862be66d (
plain) (
tree)
|
|
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
|