v1.2.0

README.md

@@ -175,10 +175,11 @@ It was onle basic introduction to the `Table` class. To learn more let's take a
 
 Factory method to instantiate `Table` class. This method is async and it should be used with await keyword or as a `Promise`. If `references` argument is provided foreign keys will be checked on any reading operation.
 
-- `source (String/Array[]/Function)` - data source (one of):
+- `source (String/Array[]/Stream/Function)` - data source (one of):
   - local CSV file (path)
   - remote CSV file (url)
   - array of arrays representing the rows
+  - readable stream with CSV file contents
   - function returning readable stream with CSV file contents
 - `schema (Object)` - data schema in all forms supported by `Schema` class
 - `strict (Boolean)` - strictness option to pass to `Schema` constructor
@@ -597,7 +598,12 @@ The `descriptor` variable is now a JSON object:
 
 This funcion is async so it has to be used with `await` keyword or as a `Promise`.
 
-- `source (String/Array[]/Stream)` - data source
+- `source (String/Array[]/Stream/Function)` - data source (one of):
+  - local CSV file (path)
+  - remote CSV file (url)
+  - array of arrays representing the rows
+  - readable stream with CSV file contents
+  - function returning readable stream with CSV file contents
 - `headers (String[])` - array of headers
 - `options (Object)` - any `Table.load` options
 - `(errors.TableSchemaError)` - raises any error occured in the process
@@ -636,6 +642,11 @@ $ npm run build
 
 Here described only breaking and the most important changes. The full changelog and documentation for all released versions could be found in nicely formatted [commit history](https://github.com/frictionlessdata/tableschema-js/commits/master).
 
+### v1.2
+
+New API added:
+- `Table.load` and `infer` now accept Node Stream as a `source` argument
+
 ### v1.1
 
 New API added:

package.json

@@ -1,6 +1,6 @@
 {
   "name": "tableschema",
-  "version": "1.1.1",
+  "version": "1.2.0",
   "description": "A library for working with Table Schema in Javascript.",
   "license": "MIT",
   "main": "lib/index.js",

src/table.js

@@ -53,15 +53,7 @@ class Table {
    * https://github.com/frictionlessdata/tableschema-js#table
    */
   async iter({keyed, extended, cast=true, relations=false, stream=false}={}) {
-
-    // Get row stream
     let source = this._source
-    if (source.readable) {
-      const duplicateStream = this._source.pipe(new PassThrough())
-      this._source = duplicateStream.pipe(new PassThrough())
-      source = duplicateStream.pipe(new PassThrough())
-    }
-    const rowStream = await createRowStream(source, this._parserOptions)
 
     // Prepare unique checks
     let uniqueFieldsCache = {}
@@ -71,6 +63,16 @@ class Table {
       }
     }
 
+    // Multiplicate node stream
+    if (source.readable) {
+      const duplicateStream = this._source.pipe(new PassThrough())
+      this._source = duplicateStream.pipe(new PassThrough())
+      source = duplicateStream.pipe(new PassThrough())
+    }
+
+    // Get row stream
+    const rowStream = await createRowStream(source, this._parserOptions)
+
     // Get table row stream
     let rowNumber = 0
     let tableRowStream = rowStream.pipe(csv.transform(row => {
@@ -228,17 +230,17 @@ async function createRowStream(source, parserOptions) {
     stream = source()
     stream = stream.pipe(parser)
 
+  // Node stream
+  } else if (source.readable) {
+    stream = source
+    stream = stream.pipe(parser)
+
   // Inline source
   } else if (isArray(source)) {
     stream = new Readable({objectMode: true})
     for (const row of source) stream.push(row)
     stream.push(null)
 
-  // Row stream
-  } else if (source.readable) {
-    stream = source
-    stream = stream.pipe(parser)
-
   // Remote source
   } else if (helpers.isRemotePath(source)) {
     if (config.IS_BROWSER) {