fix cleanPipe()

This commit is contained in:
2017-03-04 14:26:10 +01:00
parent 5401e5e008
commit addf20995a
3 changed files with 10 additions and 4 deletions

View File

@ -1,5 +1,9 @@
import * as plugins from './smartstream.plugins'
// interfaces
import { Transform } from 'stream'
export interface IErrorFunction {
(err): any
}
@ -91,7 +95,7 @@ export class Smartstream {
}
export let cleanPipe = () => {
plugins.through2.obj(
return plugins.through2.obj(
(file, enc, cb) => {
cb()
},