basic.js 825 B

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. var concat = require('../')
  2. var stream = require('stream')
  3. var test = require('tape')
  4. test('basic', function (t) {
  5. t.plan(2)
  6. var s = new stream.PassThrough()
  7. concat(s, function (err, buf) {
  8. t.error(err)
  9. t.deepEqual(buf, Buffer.from('abc123456789'))
  10. })
  11. s.write('abc')
  12. setTimeout(function () {
  13. s.write('123')
  14. }, 10)
  15. setTimeout(function () {
  16. s.write('456')
  17. }, 20)
  18. setTimeout(function () {
  19. s.end('789')
  20. }, 30)
  21. })
  22. test('error', function (t) {
  23. t.plan(2)
  24. var s = new stream.PassThrough()
  25. concat(s, function (err, buf) {
  26. t.ok(err, 'got expected error')
  27. t.ok(!buf)
  28. })
  29. s.write('abc')
  30. setTimeout(function () {
  31. s.write('123')
  32. }, 10)
  33. setTimeout(function () {
  34. s.write('456')
  35. }, 20)
  36. setTimeout(function () {
  37. s.emit('error', new Error('error'))
  38. }, 30)
  39. })