Merge pull request #1 from CodeMan99/producer-class

Move the Producer class to module scope.

.travis.yml

@@ -0,0 +1,9 @@
+sudo: false
+language: node_js
+node_js:
+  - "0.10"
+  - "0.12"
+  - "4"
+  - "6"
+  - "8"
+  - "9"

index.js

@@ -8,6 +8,19 @@ if(Readable === undefined) {
   Readable = require('readable-stream')
 }
 
+function Producer(source, options) {
+  Readable.call(this, options)
+  this._index = 0
+  this._source = source
+}
+
+util.inherits(Producer, Readable)
+
+Producer.prototype._read = function() {
+  // evaluate the source, and push the results.
+  this._source(this._index++)
+}
+
 // from
 //
 // a stream that reads from an source.
@@ -22,18 +35,6 @@ function from(source, options) {
     return from(streamify(source, options), options)
   }
 
-  function Producer(source, options) {
-    Readable.call(this, options)
-    this._index = 0
-  }
-
-  util.inherits(Producer, Readable)
-
-  Producer.prototype._read = function() {
-    // evaluate the source, and push the results.
-    source.call(this, this._index++)
-  }
-
   return new Producer(source, options)
 }
 

test.js

@@ -1,5 +1,6 @@
 var assert = require('assert')
   , from = require('./')
+  , Stream = require('stream').Stream
 
 var random = ['hello', 'goodbye', 1, 2, 3]
 
@@ -17,9 +18,14 @@ var i = 0
 
 characters.on('data', function(data) {
   assert.equal(data, sentence[i++])
+  assert(i)
+})
+
+from(function(index) {
+	assert(index === 0)
+	assert(this instanceof Stream)
 })
 
-assert(i)