|
@@ -117,6 +117,7 @@ function _write(chunk, encoding, callback) {
|
|
programmer a useful error and to stop the stream properly */
|
|
programmer a useful error and to stop the stream properly */
|
|
this.call.cancelWithStatus(grpc.status.INTERNAL, 'Serialization failure');
|
|
this.call.cancelWithStatus(grpc.status.INTERNAL, 'Serialization failure');
|
|
callback(e);
|
|
callback(e);
|
|
|
|
+ return;
|
|
}
|
|
}
|
|
if (_.isFinite(encoding)) {
|
|
if (_.isFinite(encoding)) {
|
|
/* Attach the encoding if it is a finite number. This is the closest we
|
|
/* Attach the encoding if it is a finite number. This is the closest we
|