@Override
    public void onNext(final T value) {
        String respData = JsonMessage.getDataFromDynamicMessage((DynamicMessage) value);
        if (StringUtils.isNotBlank(respData)) {
            respData = respData.trim();
            if (StringUtils.startsWith(respData, "{") && StringUtils.endsWith(respData, "}")) {
                // standardized json output.
                grpcResponse.getResults().add(GSON.fromJson(respData,
                        new TypeToken<HashMap<String, Object>>() {
                        }.getType()));
            }
        } else {
            grpcResponse.getResults().add(respData);
        }
    }
New instance.

@param results results
@param <T> t
@return message message
shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-grpc/src/main/java/org/apache/shenyu/plugin/grpc/proto/MessageWriter.java