docs: @ExperimentalApi("https://github.com/grpc/grpc-java/issues/1712")
    public static ServerServiceDefinition useInputStreamMessages(
        final ServerServiceDefinition serviceDef) {
      final MethodDescriptor.Marshaller<InputStream> marshaller =
          new MethodDescriptor.Marshaller<InputStream>() {
        @Override
        public InputStream stream(final InputStream value) {
          return value;
        }
  
        @Override
        public InputStream parse(final InputStream stream) {
          if (stream.markSupported()) {
            return stream;
          } else {
            return new BufferedInputStream(stream);
          }
        }
      };
  
      return useMarshalledMessages(serviceDef, marshaller);
    }