diff --git a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java index bcf4e9bff3500..a9dc8f711fe0b 100644 --- a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java +++ b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java @@ -142,7 +142,6 @@ public void cancel() { } private Future writeMessage(GrpcMessage message, boolean end) { - if (cancelled) { throw new IllegalStateException("The stream has been cancelled"); } @@ -164,6 +163,7 @@ private Future writeMessage(GrpcMessage message, boolean end) { responseHeaders.add(header.getKey(), header.getValue()); } } + responseHeaders.set("content-type", "application/json"); }