Streamify -> Stringify

Author: jonathanong

index.js

@@ -1,38 +1,38 @@
 /*
 
-  db.collection.find().stream().pipe(Streamify()).pipe(res)
+  db.collection.find().stream().pipe(Stringify()).pipe(res)
 
 */
 var Transform = require('stream').Transform
 var util = require('util')
 
-util.inherits(Streamify, Transform)
+util.inherits(Stringify, Transform)
 
-module.exports = Streamify
+module.exports = Stringify
 
-function Streamify(options) {
-  if (!(this instanceof Streamify))
-    return new Streamify(options || {})
+function Stringify(options) {
+  if (!(this instanceof Stringify))
+    return new Stringify(options || {})
 
   options = options || {}
   options.objectMode = true
   Transform.call(this, options)
 }
 
 // Flags
-Streamify.prototype.destroyed = false
-Streamify.prototype.started = false
+Stringify.prototype.destroyed = false
+Stringify.prototype.started = false
 
 // Array delimiters
-Streamify.prototype.open = new Buffer('[\n', 'utf8')
-Streamify.prototype.seperator = new Buffer('\n,\n', 'utf8')
-Streamify.prototype.close = new Buffer('\n]\n', 'utf8')
+Stringify.prototype.open = new Buffer('[\n', 'utf8')
+Stringify.prototype.seperator = new Buffer('\n,\n', 'utf8')
+Stringify.prototype.close = new Buffer('\n]\n', 'utf8')
 
 // JSON.stringify options
-Streamify.prototype.replacer = null
-Streamify.prototype.space = 0
+Stringify.prototype.replacer = null
+Stringify.prototype.space = 0
 
-Streamify.prototype._transform = function (doc, encoding, cb) {
+Stringify.prototype._transform = function (doc, encoding, cb) {
   if (this.destroyed)
     return
 
@@ -56,7 +56,7 @@ Streamify.prototype._transform = function (doc, encoding, cb) {
   process.nextTick(cb)
 }
 
-Streamify.prototype._flush = function (cb) {
+Stringify.prototype._flush = function (cb) {
   if (this.destroyed)
     return
 
@@ -68,7 +68,7 @@ Streamify.prototype._flush = function (cb) {
   process.nextTick(cb)
 }
 
-Streamify.prototype.destroy = function () {
+Stringify.prototype.destroy = function () {
   if (!this.destroyed) {
     this.emit('close')
     this.destroyed = true

test.js

@@ -2,15 +2,15 @@ var assert = require('assert')
 var PassThrough = require('stream').PassThrough
 var cat = require('cat-stream')
 
-var streamify = require('./')
+var Stringify = require('./')
 
 describe('Streamify()', function () {
   it('should work with an empty stream', function (done) {
     var stream = new PassThrough({
       objectMode: true
     })
 
-    stream.pipe(streamify()).pipe(cat(function (err, buf) {
+    stream.pipe(Stringify()).pipe(cat(function (err, buf) {
       assert.ifError(err)
       assert.equal(buf.toString('utf8'), '[\n\n]\n')
       done()
@@ -24,7 +24,7 @@ describe('Streamify()', function () {
       objectMode: true
     })
 
-    stream.pipe(streamify()).pipe(cat(function (err, buf) {
+    stream.pipe(Stringify()).pipe(cat(function (err, buf) {
       assert.ifError(err)
       assert.equal(buf.toString('utf8'), '[\n{}\n]\n')
       done()
@@ -39,7 +39,7 @@ describe('Streamify()', function () {
       objectMode: true
     })
 
-    stream.pipe(streamify()).pipe(cat(function (err, buf) {
+    stream.pipe(Stringify()).pipe(cat(function (err, buf) {
       assert.ifError(err)
       assert.equal(buf.toString('utf8'), '[\n{}\n,\n{}\n]\n')
       done()
@@ -55,7 +55,7 @@ describe('Streamify()', function () {
       objectMode: true
     })
 
-    stream.pipe(streamify()).pipe(cat(function (err, buf) {
+    stream.pipe(Stringify()).pipe(cat(function (err, buf) {
       assert.ifError(err)
       assert.equal(buf.toString('utf8'), '[\n"hello"\n]\n')
       done()
@@ -70,7 +70,7 @@ describe('Streamify()', function () {
       objectMode: true
     })
 
-    stream.pipe(streamify({
+    stream.pipe(Stringify({
       encoding: 'utf8'
     })).once('data', function (chunk) {
       assert.equal(typeof chunk, 'string')
@@ -86,7 +86,7 @@ describe('Streamify()', function () {
       objectMode: true
     })
 
-    var stringify = streamify()
+    var stringify = Stringify()
     stringify.space = 2
 
     var obj = {