【发布时间】:2020-12-26 14:48:42
【问题描述】:
StreamObserver<RouteSummary> responseObserver = new StreamObserver<RouteSummary>() {
@Override
public void onNext(RouteSummary summary) {
LOGGER.info("Action.");
}
@Override
public void onError(Throwable t) {
LOGGER.error("Error.");
}
@Override
public void onCompleted() {
LOGGER.info("Completed.");
}
};
有一个 grpc 连接和客户端流。它已启动,但如果 Grpc 客户端重新启动, 我怎样才能在他们停止的地方继续收到回复。
【问题讨论】:
标签: java stream connection grpc observers