summary refs log tree commit diff stats
path: root/tests/cnstseq
diff options
context:
space:
mode:
Diffstat (limited to 'tests/cnstseq')
0 files changed, 0 insertions, 0 deletions
da421530bbcd43c7ab74a2eb'>3f3853945 ^
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
54
           
                            



















































                                                                      
discard """
  file: "tasyncRecvLine.nim"
  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()