fix observable disposable

This commit is contained in:
Juan Tejada 2016-12-02 12:09:35 -08:00
parent 5ac3fe9ea8
commit f1491fa4cc

View file

@ -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;
});