Skip to content

Instantly share code, notes, and snippets.

@nlf

nlf/also works.js

Created December 20, 2013 20:02
Show Gist options
  • Save nlf/8060534 to your computer and use it in GitHub Desktop.
Save nlf/8060534 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
also works.js
Person.extendModel({
all: function () {
var stream = new Readable({ objectMode: true });
stream.push({ test: true});
stream.push(null);
return stream;
}
});
Raw
broken.js
Person.extendModel({
all: function () {
var stream = new Readable({ objectMode: true });
var i = 0;
var timer = setInterval(function () {
if (i < 10) {
stream.push({ test: true });
i += 1;
} else if (i === 10) {
stream.push(null);
clearInterval(timer);
}
}, 100);
return stream;
}
});
Raw
works.js
Person.extendModel({
all: function () {
var stream = new Readable({ objectMode: true });
var i = 0;
stream._read = function () {
var timer = setInterval(function () {
if (i < 10) {
stream.push({ test: true });
i += 1;
} else if (i === 10) {
stream.push(null);
clearInterval(timer);
}
}, 100);
}
return stream;
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment