31 lines
625 B
JavaScript
31 lines
625 B
JavaScript
var test = require('tape');
|
|
var read = require('..');
|
|
var co = require('co');
|
|
var wait = require('co-wait');
|
|
var through = require('through');
|
|
|
|
test('backpressure', function(t) {
|
|
var times = 3;
|
|
t.plan(2 + times);
|
|
|
|
co(function*() {
|
|
var stream = through();
|
|
|
|
process.nextTick(function() {
|
|
(function next() {
|
|
stream.queue('foo');
|
|
if (--times) setTimeout(next, 10);
|
|
else stream.end();
|
|
})();
|
|
});
|
|
|
|
var chunk;
|
|
while (chunk = yield read(stream)) {
|
|
t.equal(chunk, 'foo', 'data event');
|
|
yield wait(50);
|
|
}
|
|
|
|
t.ok(true, 'ended');
|
|
}, t.error.bind(t));
|
|
});
|