add cleanPipe()

ts/index.ts

@@ -1,91 +1,102 @@
 import * as plugins from './smartstream.plugins'
 
 export interface IErrorFunction {
-    (err): any
+  (err): any
 }
 
 export interface ICustomEventFunction {
-    (): any
+  (): any
 }
 
 export interface ICustomEventObject {
-    eventName: string
-    eventFunction: ICustomEventFunction
+  eventName: string
+  eventFunction: ICustomEventFunction
 }
 
 /**
  * class Smartstream handles 
  */
 export class Smartstream {
-    private streamArray = []
-    private customEventObjectArray: ICustomEventObject[] = []
-    private streamStartedDeferred = plugins.q.defer()
+  private streamArray = []
+  private customEventObjectArray: ICustomEventObject[] = []
+  private streamStartedDeferred = plugins.q.defer()
 
-    /**
-     * constructor
-     */
-    constructor(streamArrayArg: any[]) {
-        this.streamArray = streamArrayArg
+  /**
+   * constructor
+   */
+  constructor(streamArrayArg: any[]) {
+    this.streamArray = streamArrayArg
+  }
+
+  /**
+   * make something with the stream itself
+   */
+  streamStarted(): plugins.q.Promise<any> {
+    return this.streamStartedDeferred.promise
+  }
+
+  /**
+   * attach listener to custom event
+   */
+  onCustomEvent(eventNameArg: string, eventFunctionArg: ICustomEventFunction) {
+    this.customEventObjectArray.push({
+      eventName: eventNameArg,
+      eventFunction: eventFunctionArg
+    })
+  }
+
+  /**
+   * run the stream
+   * @returns Promise
+   */
+  run(): plugins.q.Promise<void> {
+    let done = plugins.q.defer<void>()
+
+    // clone Array
+    let streamExecutionArray = []
+    for (let streamItem of this.streamArray) { streamExecutionArray.push(streamItem) }
+
+    // combine the stream
+    let finalStream = null
+    let firstIteration: boolean = true
+    for (let stream of streamExecutionArray) {
+      if (firstIteration === true) {
+        finalStream = stream
+      }
+      stream.on('error', (err) => {
+        done.reject(err)
+      })
+      for (let customEventObject of this.customEventObjectArray) {
+        stream.on(customEventObject.eventName, customEventObject.eventFunction)
+      }
+      if (!firstIteration) {
+        finalStream = finalStream.pipe(stream)
+      }
+      firstIteration = false
     }
 
-    /**
-     * make something with the stream itself
-     */
-    streamStarted(): plugins.q.Promise<any> {
-        return this.streamStartedDeferred.promise
+    this.streamStartedDeferred.resolve()
+
+    finalStream.on('end', function () {
+      done.resolve()
+    })
+    finalStream.on('close', function () {
+      done.resolve()
+    })
+    finalStream.on('finish', function () {
+      done.resolve()
+    })
+    return done.promise
+  }
+}
+
+export let cleanPipe = () => {
+  plugins.through2.obj(
+    (file, enc, cb) => {
+      cb()
+    },
+    (cb) => {
+      cb()
     }
-
-    /**
-     * attach listener to custom event
-     */
-    onCustomEvent(eventNameArg: string, eventFunctionArg: ICustomEventFunction) {
-        this.customEventObjectArray.push({
-            eventName: eventNameArg,
-            eventFunction: eventFunctionArg
-        })
-    }
-
-    /**
-     * run the stream
-     * @returns Promise
-     */
-    run(): plugins.q.Promise<void> {
-        let done = plugins.q.defer<void>()
-
-        // clone Array
-        let streamExecutionArray = []
-        for (let streamItem of this.streamArray) { streamExecutionArray.push(streamItem) }
-
-        // combine the stream
-        let finalStream = null
-        let firstIteration: boolean = true
-        for (let stream of streamExecutionArray) {
-            if (firstIteration === true) {
-                finalStream = stream
-            }
-            stream.on('error', (err) => {
-                done.reject(err)
-            })
-            for (let customEventObject of this.customEventObjectArray) {
-                stream.on(customEventObject.eventName, customEventObject.eventFunction)
-            }
-            if (!firstIteration) {
-                finalStream = finalStream.pipe(stream)
-            }
-            firstIteration = false
-        }
-    
-        this.streamStartedDeferred.resolve()
-
-        finalStream.on('end',function(){
-            done.resolve()
-        })
-        finalStream.on('close',function(){
-            done.resolve()
-        })
-        finalStream.on('finish',function(){
-            done.resolve()
-        })
-        return done.promise
-    }
-}
+  )
+}

ts/smartstream.plugins.ts

@@ -1,2 +1,3 @@
 import 'typings-global'
 export import q = require('q')
+export import through2 = require('through2')