1 | var test = require('tape');
|
2 | var pipeline = require('..').pipeline;
|
3 | var stream = require('..');
|
4 | var Buffer = require('safe-buffer').Buffer;
|
5 |
|
6 | test('supports pipeline', function(t) {
|
7 | t.plan(4);
|
8 | var readable = new stream.Readable({
|
9 | read: function () {
|
10 | this.push(Buffer.from('chunk', 'ascii'));
|
11 | }
|
12 | });
|
13 | var transform1 = new stream.Transform({
|
14 | transform: function (chunk, enc, cb) {
|
15 | cb(new Error('fail'));
|
16 | }
|
17 | });
|
18 | var transform2 = new stream.PassThrough();
|
19 | transform2.on('close', function () {
|
20 | t.pass('transform2.close called');
|
21 | });
|
22 | var writable = new stream.Writable({
|
23 | write: function (chunk, enc, cb) { cb(); }
|
24 | });
|
25 | writable.on('close', function () {
|
26 | t.pass('writable.close called');
|
27 | });
|
28 |
|
29 | pipeline(
|
30 | readable,
|
31 | transform1,
|
32 | transform2,
|
33 | writable,
|
34 | function(err) {
|
35 | t.ok(err);
|
36 | t.equal(err.message, 'fail');
|
37 | });
|
38 | });
|