Added callback definitions to throught2

This commit is contained in:
Georgios Valotasios
2015-12-20 18:52:49 +01:00
parent 40c60850ad
commit cba118b92f
2 changed files with 20 additions and 5 deletions
+11
View File
@@ -22,6 +22,12 @@ rws = through2(function (entry: any, enc: string, callback: () => void) {
});
rws = through2(function (entry: any, enc: string, callback: (error: any, data?: any) => void) {
callback(null, 'foo');
}, (flushCallback: () => void) => {
flushCallback();
});
rws = through2(function (entry: any, enc: string, callback: () => void) {
this.push('foo');
callback();
@@ -42,3 +48,8 @@ rws = through2.obj(function (entry: any, enc: string, callback: () => void) {
callback();
});
rws = through2.obj(function (entry: any, enc: string, callback: (err: any) => void) {
callback('Oups!');
}, (flashCallback) => {
flashCallback();
});