diff --git a/libp2p/daemon/daemonapi.nim b/libp2p/daemon/daemonapi.nim
index c423e75..04d7e26 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: