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() })