martin-g commented on a change in pull request #1354:
URL: https://github.com/apache/avro/pull/1354#discussion_r723635522
##########
File path: lang/js/lib/protocols.js
##########
@@ -1099,6 +1099,8 @@ MessageDecoder.prototype._flush = function () {
this.emit('error', new Error('trailing data'));
} else if (this._empty) {
this.emit('error', new Error('no message decoded'));
+ } else {
+ this.emit('finish');
Review comment:
This fixes the issue with Node.js 16 but it is a mystery to me why
`finish` event is not emitted automatically on the Transform stream after the
reabable.end().
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
