【发布时间】:2020-10-07 08:06:42
【问题描述】:
@Override
public void response(RequestApp request, Grpc.Stub asyncStub) {
StreamObserver<Dto> streamObserver = new StreamObserver<Dto>() {
@Override
public void onNext(Response response) {
LOGGER.info("Response is received.");
}
@Override
public void onError(Throwable thrwbl) {
LOGGER.error("Get error.");
}
@Override
public void onCompleted() {
LOGGER.info("Stream is completed.");
}
};
asyncStub.method(request, streamObserver);
}
Grpc 客户端代码与上面相同。这里有服务器端流。如果客户端重启,服务器端流启动后,如何继续这个流?
【问题讨论】:
标签: java stream grpc server-side stub