@Override
            public void onNext(DeframedMessage message) {
                // We know that we don't support compression, so this is always a ByteBuf.
                final ByteBuf buf = message.buf();
                assert buf != null;
                final HttpData unframedContent = HttpData.wrap(buf);
                unframedHeaders.contentType(MediaType.JSON_UTF_8);

                final AggregatedHttpResponse existingResponse = AggregatedHttpResponse.of(
                        unframedHeaders.build(),
                        unframedContent);

                if (responseConverter != null) {
                    final AggregatedHttpResponse convertedResponse = responseConverter.apply(existingResponse);
                    res.complete(convertedResponse.toHttpResponse());
                } else {
                    res.complete(existingResponse.toHttpResponse());
                }
            }
Creates a new instance that decorates the specified {@link HttpService}.
grpc/src/main/java/com/linecorp/armeria/server/grpc/AbstractUnframedGrpcService.java