diff --git a/src/server.js b/src/server.js index 51bb99ee..da9c6b2d 100644 --- a/src/server.js +++ b/src/server.js @@ -133,6 +133,7 @@ function sendUnaryResponse(call, value, serialize, metadata, flags) { } catch (e) { e.code = grpc.status.INTERNAL; handleError(e); + return; } message.grpcWriteFlags = flags; end_batch[grpc.opType.SEND_MESSAGE] = message;