Test stream events
This commit is contained in:
parent
3302cdcd9c
commit
41e22df257
@ -335,8 +335,10 @@ function ExportRequest (ostream, callback, beforeSink) {
|
|||||||
logger.info({ custom: true }, 'Destroying stream');
|
logger.info({ custom: true }, 'Destroying stream');
|
||||||
that.istream.destroy();
|
that.istream.destroy();
|
||||||
}
|
}
|
||||||
}).on('open', function() {
|
}).on('error', function(e) {
|
||||||
logger.info({ custom: true }, 'Open a stream');
|
logger.info({ custom: true, errormessage: e }, 'Close stream error');
|
||||||
|
}).on('finish', function () {
|
||||||
|
logger.info({ custom: true }, 'Stream finished');
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -357,7 +359,7 @@ ExportRequest.prototype.sendFile = function (err, filename, callback) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
logger.info({ custom: true }, 'Sending file: on open');
|
logger.info({ custom: true }, 'Sending file: on open');
|
||||||
logger.info({ custom: true, isdestroyed: that.ostream.destroyed }, 'Ostream');
|
logger.info({ custom: true, readable: that.ostream.req.readable }, 'Ostream');
|
||||||
|
|
||||||
that.istream
|
that.istream
|
||||||
.pipe(that.ostream)
|
.pipe(that.ostream)
|
||||||
|
Loading…
Reference in New Issue
Block a user