1234567891011121314151617181920212223242526272829303132333435363738394041 |
- var concat = require('../')
- var stream = require('stream')
- var test = require('tape')
- test('basic', function (t) {
- t.plan(2)
- var s = new stream.PassThrough()
- concat(s, function (err, buf) {
- t.error(err)
- t.deepEqual(buf, Buffer.from('abc123456789'))
- })
- s.write('abc')
- setTimeout(function () {
- s.write('123')
- }, 10)
- setTimeout(function () {
- s.write('456')
- }, 20)
- setTimeout(function () {
- s.end('789')
- }, 30)
- })
- test('error', function (t) {
- t.plan(2)
- var s = new stream.PassThrough()
- concat(s, function (err, buf) {
- t.ok(err, 'got expected error')
- t.ok(!buf)
- })
- s.write('abc')
- setTimeout(function () {
- s.write('123')
- }, 10)
- setTimeout(function () {
- s.write('456')
- }, 20)
- setTimeout(function () {
- s.emit('error', new Error('error'))
- }, 30)
- })
|