diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py
index cceba08a..dc6f4d52 100644
--- a/libp2p/pubsub/pubsub.py
+++ b/libp2p/pubsub/pubsub.py
@@ -245,7 +245,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?