summaryrefslogtreecommitdiff
path: root/node_modules/split2/test.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/split2/test.js')
-rw-r--r--node_modules/split2/test.js149
1 files changed, 149 insertions, 0 deletions
diff --git a/node_modules/split2/test.js b/node_modules/split2/test.js
new file mode 100644
index 00000000..d227d4ac
--- /dev/null
+++ b/node_modules/split2/test.js
@@ -0,0 +1,149 @@
+
+var test = require('tap').test
+ , split = require('./')
+ , callback = require('callback-stream')
+ , strcb = callback.bind(null, { decodeStrings: false })
+ , objcb = callback.bind(null, { objectMode: true })
+
+test('split two lines on end', function(t) {
+ t.plan(1)
+
+ var input = split()
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, ['hello', 'world'])
+ }))
+
+ input.end('hello\nworld')
+})
+
+test('split two lines on two writes', function(t) {
+ t.plan(1)
+
+ var input = split()
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, ['hello', 'world'])
+ }))
+
+ input.write('hello')
+ input.write('\nworld')
+ input.end()
+})
+
+test('accumulate multiple writes', function(t) {
+ t.plan(1)
+
+ var input = split()
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, ['helloworld'])
+ }))
+
+ input.write('hello')
+ input.write('world')
+ input.end()
+})
+
+test('split using a custom string matcher', function(t) {
+ t.plan(1)
+
+ var input = split('~')
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, ['hello', 'world'])
+ }))
+
+ input.end('hello~world')
+})
+
+test('split using a custom regexp matcher', function(t) {
+ t.plan(1)
+
+ var input = split(/~/)
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, ['hello', 'world'])
+ }))
+
+ input.end('hello~world')
+})
+
+test('support an option argument', function(t) {
+ t.plan(2)
+
+ var input = split({ highWatermark: 2 })
+
+ input.pipe(strcb(function(err, list) {
+ t.notOk(err, 'no errors')
+ t.deepEqual(list, ['hello', 'world'])
+ }))
+
+ input.end('hello\nworld')
+})
+
+test('support a mapper function', function(t) {
+ t.plan(2)
+
+ var a = { a: '42' }
+ , b = { b: '24' }
+ var input = split(JSON.parse)
+
+ input.pipe(objcb(function(err, list) {
+ t.notOk(err, 'no errors')
+ t.deepEqual(list, [a, b])
+ }))
+
+ input.write(JSON.stringify(a))
+ input.write('\n')
+ input.end(JSON.stringify(b))
+})
+
+test('split lines windows-style', function(t) {
+ t.plan(1)
+
+ var input = split()
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, ['hello', 'world'])
+ }))
+
+ input.end('hello\r\nworld')
+})
+
+test('splits a buffer', function(t) {
+ t.plan(1)
+
+ var input = split()
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, ['hello', 'world'])
+ }))
+
+ input.end(new Buffer('hello\nworld'))
+})
+
+test('do not end on undefined', function(t) {
+ t.plan(1)
+
+ var input = split(function(line) {})
+
+ input.pipe(strcb(function(err, list) {
+ t.deepEqual(list, [])
+ }))
+
+ input.end(new Buffer('hello\nworld'))
+})
+
+test('has destroy method', function(t) {
+ t.plan(1)
+
+ var input = split(function(line) {})
+
+ input.on('close', function() {
+ t.ok(true, 'close emitted')
+ t.end()
+ })
+
+ input.destroy()
+}) \ No newline at end of file