blob: 92d438a60e26e9446129a75cd7859a7024bb9df4 (
plain) (
tree)
985113a88 ^
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
|