From b0c919aab75262ae11e194c80069a0011e9895c2 Mon Sep 17 00:00:00 2001
From: mhchia <kevin.mh.chia@gmail.com>
Date: Tue, 24 Sep 2019 13:34:26 +0800
Subject: [PATCH] Add the missing `await`

---
 libp2p/pubsub/pubsub.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py
index e413b282..55b5a1c8 100644
--- a/libp2p/pubsub/pubsub.py
+++ b/libp2p/pubsub/pubsub.py
@@ -241,7 +241,7 @@ class Pubsub:
             await self.continuously_read_stream(stream)
         except (StreamEOF, StreamReset) as error:
             logger.debug("fail to read from stream, error=%s", error)
-            stream.reset()
+            await stream.reset()
             # TODO: what to do when the stream is terminated?
             # disconnect the peer?