类io.grpc.reflection.v1alpha.ListServiceResponse源码实例Demo

下面列出了怎么用io.grpc.reflection.v1alpha.ListServiceResponse的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: grpc-nebula-java   文件: ProtoReflectionService.java
private void listServices(ServerReflectionRequest request) {
  ListServiceResponse.Builder builder = ListServiceResponse.newBuilder();
  for (String serviceName : serverReflectionIndex.getServiceNames()) {
    builder.addService(ServiceResponse.newBuilder().setName(serviceName));
  }
  serverCallStreamObserver.onNext(
      ServerReflectionResponse.newBuilder()
          .setValidHost(request.getHost())
          .setOriginalRequest(request)
          .setListServicesResponse(builder)
          .build());
}
 
源代码2 项目: quarkus   文件: ReflectionService.java
private ServerReflectionResponse getServiceList(ServerReflectionRequest request) {
    ListServiceResponse response = index.getServiceNames().stream()
            .map(new Function<String, ServiceResponse>() { // NOSONAR
                @Override
                public ServiceResponse apply(String s) {
                    return ServiceResponse.newBuilder().setName(s).build();
                }
            })
            .collect(new Supplier<ListServiceResponse.Builder>() {
                @Override
                public ListServiceResponse.Builder get() {
                    return ListServiceResponse.newBuilder();
                }
            },
                    new BiConsumer<ListServiceResponse.Builder, ServiceResponse>() {
                        @Override
                        public void accept(ListServiceResponse.Builder builder, ServiceResponse value) {
                            builder.addService(value);
                        }
                    },
                    new BiConsumer<ListServiceResponse.Builder, ListServiceResponse.Builder>() { // NOSONAR
                        @Override
                        public void accept(ListServiceResponse.Builder b1,
                                ListServiceResponse.Builder b2) {
                            b1.addAllService(b2.getServiceList());
                        }
                    })
            .build();

    return ServerReflectionResponse.newBuilder()
            .setValidHost(request.getHost())
            .setOriginalRequest(request)
            .setListServicesResponse(response)
            .build();
}
 
源代码3 项目: grpc-java   文件: ProtoReflectionService.java
private void listServices(ServerReflectionRequest request) {
  ListServiceResponse.Builder builder = ListServiceResponse.newBuilder();
  for (String serviceName : serverReflectionIndex.getServiceNames()) {
    builder.addService(ServiceResponse.newBuilder().setName(serviceName));
  }
  serverCallStreamObserver.onNext(
      ServerReflectionResponse.newBuilder()
          .setValidHost(request.getHost())
          .setOriginalRequest(request)
          .setListServicesResponse(builder)
          .build());
}
 
源代码4 项目: grpc-swagger   文件: ServerReflectionClient.java
private void handleListServiceResponse(ListServiceResponse response) {
    ImmutableList.Builder<String> servicesBuilder = ImmutableList.builder();
    response.getServiceList().forEach(service -> servicesBuilder.add(service.getName()));
    resultFuture.set(servicesBuilder.build());
    requestStream.onCompleted();
}
 
源代码5 项目: milkman   文件: ServerReflectionClient.java
private void handleListServiceRespones(ListServiceResponse response) {
  ImmutableList.Builder<String> servicesBuilder = ImmutableList.builder();
  response.getServiceList().forEach(service -> servicesBuilder.add(service.getName()));
  resultFuture.set(servicesBuilder.build());
  requestStream.onCompleted();
}
 
源代码6 项目: grpc-swagger   文件: ServerReflectionClient.java
private void handleListServiceResponse(ListServiceResponse response) {
    ImmutableList.Builder<String> servicesBuilder = ImmutableList.builder();
    response.getServiceList().forEach(service -> servicesBuilder.add(service.getName()));
    resultFuture.set(servicesBuilder.build());
    requestStream.onCompleted();
}
 
 类所在包
 类方法
 同包方法