From 1cef1b803bfdd97dfb1b3dae18de4186b9e4e0b0 Mon Sep 17 00:00:00 2001
From: Dmitriy Ryajov <dryajov@gmail.com>
Date: Fri, 30 Aug 2019 15:55:07 -0600
Subject: [PATCH] don't await twise

---
 libp2p/connection.nim | 32 ++++++++++++++++----------------
 1 file changed, 16 insertions(+), 16 deletions(-)

diff --git a/libp2p/connection.nim b/libp2p/connection.nim
index cbe183f..ebce7ea 100644
--- a/libp2p/connection.nim
+++ b/libp2p/connection.nim
@@ -22,38 +22,38 @@ proc newConnection*(stream: LPStream): Connection =
   new result
   result.stream = stream
 
-method read*(s: Connection, n = -1): Future[seq[byte]] {.async, gcsafe.} =
-  result = await s.stream.read(n)
+method read*(s: Connection, n = -1): Future[seq[byte]] {.gcsafe.} =
+  result = s.stream.read(n)
 
 method readExactly*(s: Connection,
                     pbytes: pointer,
-                    nbytes: int): Future[void] {.async, gcsafe.} =
-  await s.stream.readExactly(pbytes, nbytes)
+                    nbytes: int): Future[void] {.gcsafe.} =
+  result = s.stream.readExactly(pbytes, nbytes)
 
 method readLine*(s: Connection,
                  limit = 0,
-                 sep = "\r\n"): Future[string] {.async, gcsafe.} =
-  result = await s.stream.readLine(limit, sep)
+                 sep = "\r\n"): Future[string] {.gcsafe.} =
+  result = s.stream.readLine(limit, sep)
 
 method readOnce*(s: Connection,
                  pbytes: pointer,
-                 nbytes: int): Future[int] {.async, gcsafe.} =
-  result = await s.stream.readOnce(pbytes, nbytes)
+                 nbytes: int): Future[int] {.gcsafe.} =
+  result = s.stream.readOnce(pbytes, nbytes)
 
 method readUntil*(s: Connection,
                   pbytes: pointer,
                   nbytes: int,
-                  sep: seq[byte]): Future[int] {.async, gcsafe.} =
-  result = await s.stream.readUntil(pbytes, nbytes, sep)
+                  sep: seq[byte]): Future[int] {.gcsafe.} =
+  result = s.stream.readUntil(pbytes, nbytes, sep)
 
-method write*(s: Connection, pbytes: pointer, nbytes: int) {.async, gcsafe.} =
-  await s.stream.write(pbytes, nbytes)
+method write*(s: Connection, pbytes: pointer, nbytes: int): Future[void] {.gcsafe.} =
+  result = s.stream.write(pbytes, nbytes)
 
-method write*(s: Connection, msg: string, msglen = -1) {.async, gcsafe.} =
-  await s.stream.write(msg, msglen)
+method write*(s: Connection, msg: string, msglen = -1): Future[void] {.gcsafe.} =
+  result = s.stream.write(msg, msglen)
 
-method write*(s: Connection, msg: seq[byte], msglen = -1) {.async, gcsafe.} =
-  await s.stream.write(msg, msglen)
+method write*(s: Connection, msg: seq[byte], msglen = -1): Future[void] {.gcsafe.} =
+  result = s.stream.write(msg, msglen)
 
 method close*(s: Connection) {.async, gcsafe.} =
   await s.stream.close()