diff --git a/packages/isomorphic-core/src/delta-stream-builder.js b/packages/isomorphic-core/src/delta-stream-builder.js
index 5b9b91491..12f4f8a75 100644
--- a/packages/isomorphic-core/src/delta-stream-builder.js
+++ b/packages/isomorphic-core/src/delta-stream-builder.js
@@ -47,8 +47,8 @@ module.exports = {
 
       const outputStream = stream.Readable();
       outputStream._read = () => { return };
-      source.subscribe((str) => outputStream.push(str))
-      request.on("disconnect", () => source.dispose());
+      const disposable = source.subscribe((str) => outputStream.push(str))
+      request.on("disconnect", () => disposable.dispose());
 
       return outputStream;
     });