diff --git a/packages/stream-management/index.js b/packages/stream-management/index.js
index c85d528b0..171b31cd2 100644
--- a/packages/stream-management/index.js
+++ b/packages/stream-management/index.js
@@ -54,7 +54,7 @@ export default function streamManagement({
     } catch {}
   }
 
-  entity.on("disconnect", () => {
+  entity.on("close", () => {
     clearTimeout(timeoutTimeout);
     clearTimeout(requestAckTimeout);
     clearTimeout(requestAckDebounce);