%PDF- <> %âãÏÓ endobj 2 0 obj <> endobj 3 0 obj <>/ExtGState<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI] >>/Annots[ 28 0 R 29 0 R] /MediaBox[ 0 0 595.5 842.25] /Contents 4 0 R/Group<>/Tabs/S>> endobj ºaâÚÎΞ-ÌE1ÍØÄ÷{òò2ÿ ÛÖ^ÔÀá TÎ{¦?§®¥kuµùÕ5sLOšuY>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<> endobj 2 0 obj<>endobj 2 0 obj<>es 3 0 R>> endobj 2 0 obj<> ox[ 0.000000 0.000000 609.600000 935.600000]/Fi endobj 3 0 obj<> endobj 7 1 obj<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI]>>/Subtype/Form>> stream
var from = require('from') var through = require('../') var tape = require('tape') tape('simple async example', function (t) { var n = 0, expected = [1,2,3,4,5], actual = [] from(expected) .pipe(through(function(data) { this.pause() n ++ setTimeout(function(){ console.log('pushing data', data) this.push(data) this.resume() }.bind(this), 300) })).pipe(through(function(data) { console.log('pushing data second time', data); this.push(data) })).on('data', function (d) { actual.push(d) }).on('end', function() { t.deepEqual(actual, expected) t.end() }) })