Skip to content
Browse files

test for buffering

  • Loading branch information...
1 parent 5f55881 commit 9038d8062ce4385fa34198d663597fae2b60b86d @dominictarr committed Sep 15, 2012
Showing with 37 additions and 0 deletions.
  1. +37 −0 test/buffering.js
View
37 test/buffering.js
@@ -0,0 +1,37 @@
+var through = require('..')
+
+// must emit end before close.
+
+exports['buffering'] = function (t) {
+ var ts = through(function (data) {
+ this.queue(data)
+ }, function () {
+ this.queue(null)
+ })
+
+ var ended = false, actual = []
+
+ ts.on('data', actual.push.bind(actual))
+ ts.on('end', function () {
+ ended = true
+ })
+
+ ts.write(1)
+ ts.write(2)
+ ts.write(3)
+ t.deepEqual(actual, [1, 2, 3])
+ ts.pause()
+ ts.write(4)
+ ts.write(5)
+ ts.write(6)
+ t.deepEqual(actual, [1, 2, 3])
+ ts.resume()
+ t.deepEqual(actual, [1, 2, 3, 4, 5, 6])
+ ts.pause()
+ ts.end()
+ t.ok(!ended)
+ ts.resume()
+ t.ok(ended)
+ t.end()
+
+}

0 comments on commit 9038d80

Please sign in to comment.
Something went wrong with that request. Please try again.