Socket
Socket
Sign inDemoInstall

through

Package Overview
Dependencies
Maintainers
1
Versions
29
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

through - npm Package Compare versions

Comparing version 2.2.1 to 2.2.2

22

package.json
{
"name": "through",
"version": "2.2.1",
"version": "2.2.2",
"description": "simplified stream contruction",
"main": "index.js",
"scripts": {
"test": "asynct test/*.js"
"test": "set -e; for t in test/*.js; do node $t; done"
},
"devDependencies": {
"stream-spec": "0",
"assertions": "2",
"asynct":"1"
"stream-spec": "~0.3.2",
"tape": "~0.2.2"
},

@@ -23,6 +22,15 @@ "keywords": [

"repository": {
"type":"git",
"type": "git",
"url": "https://github.com/dominictarr/through.git"
},
"homepage": "http://github.com/dominictarr/through"
"homepage": "http://github.com/dominictarr/through",
"testling": {
"browsers": [
"ie/6..latest",
"ff/3.6..latest",
"chrome/4..latest",
"safari/5.1..latest"
],
"files": "test/*.js"
}
}

@@ -0,1 +1,2 @@

var test = require('tape')
var through = require('..')

@@ -5,3 +6,3 @@

exports['buffering'] = function (t) {
test('buffering', function(assert) {
var ts = through(function (data) {

@@ -23,3 +24,3 @@ this.queue(data)

ts.write(3)
t.deepEqual(actual, [1, 2, 3])
assert.deepEqual(actual, [1, 2, 3])
ts.pause()

@@ -29,16 +30,15 @@ ts.write(4)

ts.write(6)
t.deepEqual(actual, [1, 2, 3])
assert.deepEqual(actual, [1, 2, 3])
ts.resume()
t.deepEqual(actual, [1, 2, 3, 4, 5, 6])
assert.deepEqual(actual, [1, 2, 3, 4, 5, 6])
ts.pause()
ts.end()
t.ok(!ended)
assert.ok(!ended)
ts.resume()
t.ok(ended)
t.end()
assert.ok(ended)
assert.end()
})
}
test('buffering has data in queue, when ends', function (assert) {
exports['buffering has data in queue, when ends'] = function (t) {
/*

@@ -68,8 +68,8 @@ * If stream ends while paused with data in the queue,

ts.end()
t.deepEqual(actual, [], 'no data written yet, still paused')
t.ok(!ended, 'end not emitted yet, still paused')
assert.deepEqual(actual, [], 'no data written yet, still paused')
assert.ok(!ended, 'end not emitted yet, still paused')
ts.resume()
t.deepEqual(actual, [1, 2, 3], 'resumed, all data should be delivered')
t.ok(ended, 'end should be emitted once all data was delivered')
t.end();
}
assert.deepEqual(actual, [1, 2, 3], 'resumed, all data should be delivered')
assert.ok(ended, 'end should be emitted once all data was delivered')
assert.end();
})

@@ -0,1 +1,2 @@

var test = require('tape')
var through = require('..')

@@ -5,3 +6,3 @@

exports['end before close'] = function (t) {
test('end before close', function (assert) {
var ts = through()

@@ -11,7 +12,7 @@ var ended = false, closed = false

ts.on('end', function () {
t.ok(!closed)
assert.ok(!closed)
ended = true
})
ts.on('close', function () {
t.ok(ended)
assert.ok(ended)
closed = true

@@ -24,7 +25,5 @@ })

ts.end()
t.ok(ended)
t.ok(closed)
t.end()
}
assert.ok(ended)
assert.ok(closed)
assert.end()
})
var test = require('tape')
var spec = require('stream-spec')
var through = require('..')
var a = require('assertions')

@@ -38,10 +38,10 @@ /*

exports['simple defaults'] = function (test) {
test('simple defaults', function(assert) {
var l = 1000
, expected = []
, expected = []
while(l--) expected.push(l * Math.random())
var t = through()
var t = through()
spec(t)

@@ -53,11 +53,11 @@ .through()

read(t, function (err, actual) {
if(err) test.error(err) //fail
a.deepEqual(actual, expected)
test.done()
assert.ifError(err)
assert.deepEqual(actual, expected)
assert.end()
})
write(expected, t)
}
});
exports['simple functions'] = function (test) {
test('simple functions', function(assert) {

@@ -78,13 +78,14 @@ var l = 1000

read(t, function (err, actual) {
if(err) test.error(err) //fail
a.deepEqual(actual, expected.map(function (data) {
assert.ifError(err)
assert.deepEqual(actual, expected.map(function (data) {
return data*2
}))
test.done()
assert.end()
})
write(expected, t)
}
exports['pauses'] = function (test) {
})
test('pauses', function(assert) {
var l = 1000

@@ -110,8 +111,8 @@ , expected = []

read(t, function (err, actual) {
if(err) test.error(err) //fail
a.deepEqual(actual, expected)
test.done()
assert.ifError(err)
assert.deepEqual(actual, expected)
assert.end()
})
write(expected, t)
}
})
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc