duplex

Author: stephenlacy

example.js

@@ -3,4 +3,5 @@ const through = require('through2')
 const stream = require('./')
 
 const req = request.get('http://localhost:8000/file.xlsx')
-stream(req).on('data', (d) => console.log(String(d)))
+  .pipe(stream())
+  .on('data', (d) => console.log(String(d)))

index.js

@@ -1,9 +1,11 @@
 const Excel = require('exceljs')
 const through = require('through2')
+const duplex = require('duplexify')
 const Stream = require('stream')
 const readable = new Stream.Readable()
 
-module.exports = (input) => {
+module.exports = () => {
+  const input = through()
   const workbook = new Excel.Workbook()
   readable._read = () => {
     let headers = null
@@ -25,5 +27,5 @@ module.exports = (input) => {
       readable.push(null)
     })
   }
-  return readable
+  return duplex(input, readable)
 }