1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
discard """
output: '''
Hello World
Hello World
'''
"""
import asyncdispatch, asyncnet
const recvLinePort = Port(6047)
proc setupTestServer(): AsyncSocket =
result = newAsyncSocket()
result.setSockOpt(OptReuseAddr, true)
result.bindAddr(recvLinePort)
result.listen()
proc testUnbuffered(): Future[void] {.async.} =
let serverSock = setupTestServer()
let serverAcceptClientFut = serverSock.accept()
let clientSock = newAsyncSocket(buffered = false)
let clientConnectFut = clientSock.connect("localhost", recvLinePort)
let serverAcceptedClient = await serverAcceptClientFut
await clientConnectFut
await serverAcceptedClient.send("Hello World\c\L")
echo await clientSock.recvLine()
clientSock.close()
serverSock.close()
proc testBuffered(): Future[void] {.async.} =
let serverSock = setupTestServer()
let serverAcceptClientFut = serverSock.accept()
let clientSock = newAsyncSocket(buffered = true)
let clientConnectFut = clientSock.connect("localhost", recvLinePort)
let serverAcceptedClient = await serverAcceptClientFut
await clientConnectFut
await serverAcceptedClient.send("Hello World\c\L")
echo await clientSock.recvLine()
clientSock.close()
serverSock.close()
waitFor testUnbuffered()
waitFor testBuffered()
|
