Na}{

File Content: `test.js`

var tape = require('tape')
var writer = require('./')

tape('is a write stream', function (t) {
  var expected = ['hello', 'world', 'verden']
  var ws = writer.obj(write)

  ws.write('hello')
  ws.write('world')
  ws.write('verden')
  ws.end(function () {
    t.same(expected.length, 0)
    t.end()
  })

  function write (data, enc, cb) {
    t.same(data, expected.shift())
    cb()
  }
})

tape('is flushable', function (t) {
  var expected = ['hello', 'world', 'verden']
  var flushed = false

  var ws = writer.obj(write, flush)

  ws.write('hello')
  ws.write('world')
  ws.write('verden')
  ws.end(function () {
    t.same(expected.length, 0)
    t.ok(flushed, 'was flushed')
    t.end()
  })

  function write (data, enc, cb) {
    t.same(data, expected.shift())
    cb()
  }

  function flush (cb) {
    flushed = true
    process.nextTick(cb)
  }
})

tape('can pass options', function (t) {
  var expected = ['hello', 'world', 'verden']
  var flushed = false

  var ws = writer({objectMode: true}, write, flush)

  ws.write('hello')
  ws.write('world')
  ws.write('verden')
  ws.end(function () {
    t.same(expected.length, 0)
    t.ok(flushed, 'was flushed')
    t.end()
  })

  function write (data, enc, cb) {
    t.same(data, expected.shift())
    cb()
  }

  function flush (cb) {
    flushed = true
    process.nextTick(cb)
  }
})

tape('emits error on destroy', function (t) {
  var expected = new Error()

  var ws = writer({objectMode: true}, function () {})

  ws.on('error', function (err) {
    t.equal(err, expected)
  })
  ws.on('close', t.end)

  ws.destroy(expected)
})

Name	Size	Permission
node_modules	---	0755
.travis.yml	69 bytes	0644
LICENSE	1079 bytes	0644
README.md	1147 bytes	0644
example.js	390 bytes	0644
index.js	1537 bytes	0644
package.json	1732 bytes	0644
test.js	1596 bytes	0644

File Content: test.js

File Content: `test.js`