stream-connect
Advanced tools
Comparing version 0.2.3 to 0.2.4
@@ -50,4 +50,4 @@ 'use strict' | ||
}) | ||
.on('pipe', function () { | ||
one.emit('pipe') | ||
.on('pipe', function (src) { | ||
one.emit('pipe', src) | ||
}) | ||
@@ -54,0 +54,0 @@ |
{ | ||
"name": "stream-connect", | ||
"author": "Lloyd Brookes <75pound@gmail.com>", | ||
"version": "0.2.3", | ||
"version": "0.2.4", | ||
"description": "Create a pipeline of connected streams", | ||
@@ -6,0 +6,0 @@ "repository": "https://github.com/75lb/stream-connect.git", |
@@ -44,3 +44,3 @@ var test = require('tape') | ||
test('pipe', function (t) { | ||
t.plan(3) | ||
t.plan(4) | ||
var pass1 = PassThrough() | ||
@@ -50,4 +50,5 @@ var pass2 = PassThrough() | ||
pass1 | ||
.on('pipe', function () { | ||
.on('pipe', function (src) { | ||
t.pass('"pipe" emitted') | ||
t.strictEqual(src, inputStream) | ||
}) | ||
@@ -64,3 +65,4 @@ .on('data', function (data) { | ||
var connected = streamConnect(pass1, pass2) | ||
fs.createReadStream('test/fixture.txt', 'utf8').pipe(connected) | ||
var inputStream = fs.createReadStream('test/fixture.txt', 'utf8') | ||
inputStream.pipe(connected) | ||
}) | ||
@@ -67,0 +69,0 @@ |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
9746
171