下面列出了怎么用io.grpc.reflection.v1alpha.ListServiceResponse的API类实例代码及写法,或者点击链接到github查看源代码。
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());
}
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();
}
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());
}
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();
}
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();
}
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();
}