From c5925d0d9af4459f60225032e5887f0b12d019ec Mon Sep 17 00:00:00 2001
From: cheatfate <eugene.kabanov@status.im>
Date: Thu, 22 Aug 2019 13:01:28 +0300
Subject: [PATCH] Fix appveyor problems.

---
 libp2p/daemon/daemonapi.nim | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/libp2p/daemon/daemonapi.nim b/libp2p/daemon/daemonapi.nim
index c423e7517..04d7e264c 100644
--- a/libp2p/daemon/daemonapi.nim
+++ b/libp2p/daemon/daemonapi.nim
@@ -488,9 +488,8 @@ proc recvMessage(conn: StreamTransport): Future[seq[byte]] {.async.} =
 proc newConnection*(api: DaemonAPI): Future[StreamTransport] =
   result = connect(api.address)
 
-proc closeConnection*(api: DaemonAPI, transp: StreamTransport) {.async.} =
-  transp.close()
-  await transp.join()
+proc closeConnection*(api: DaemonAPI, transp: StreamTransport): Future[void] =
+  result = transp.closeWait()
 
 proc socketExists(address: MultiAddress): Future[bool] {.async.} =
   try:
@@ -726,7 +725,7 @@ proc newDaemonApi*(flags: set[P2PDaemonFlags] = {},
 
   # Starting daemon process
   # echo "Starting ", cmd, " ", args.join(" ")
-  api.process = startProcess(cmd, "", args, env, {poStdErrToStdOut})
+  api.process = startProcess(cmd, "", args, env, {})
   # Waiting until daemon will not be bound to control socket.
   while true:
     if not api.process.running():
@@ -750,8 +749,7 @@ proc newDaemonApi*(flags: set[P2PDaemonFlags] = {},
 proc close*(stream: P2PStream) {.async.} =
   ## Close ``stream``.
   if P2PStreamFlags.Closed notin stream.flags:
-    stream.transp.close()
-    await stream.transp.join()
+    await stream.transp.closeWait()
     stream.transp = nil
     stream.flags.incl(P2PStreamFlags.Closed)
   else:
@@ -773,7 +771,7 @@ proc close*(api: DaemonAPI) {.async.} =
       discard tryRemoveFile($address)
     api.servers.setLen(0)
   # Closing daemon's process.
-  if NoProcessCtrl in api.flags:
+  if NoProcessCtrl notin api.flags:
     when defined(windows):
       api.process.kill()
     else: