in benchmark-base/src/main/java/org/apache/dubbo/benchmark/service/GrpcUserServiceImpl.java [35:45]
public void createUser(PagePB.Request request, StreamObserver<PagePB.Response> responseObserver) {
final PagePB.Response.Builder builder = PagePB.Response.newBuilder();
if (request.getUser() == null) {
builder.setState(false);
} else {
builder.setState(true);
}
PagePB.Response response = builder.build();
responseObserver.onNext(response);
responseObserver.onCompleted();
}