diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py
index e413b28..55b5a1c 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?