in 3-extensions/protocol/dubbo-samples-triple/src/main/java/org/apache/dubbo/sample/tri/interop/client/GrpcGreeterImpl.java [201:222]
private StreamObserver<GreeterRequest> getGreeterRequestStreamObserver(
StreamObserver<GreeterReply> streamObserver) {
return new StreamObserver<GreeterRequest>() {
@Override
public void onNext(GreeterRequest data) {
streamObserver.onNext(GreeterReply.newBuilder()
.setMessage(data.getName())
.build());
}
@Override
public void onError(Throwable throwable) {
throwable.printStackTrace();
streamObserver.onError(new IllegalStateException("Stream err"));
}
@Override
public void onCompleted() {
streamObserver.onCompleted();
}
};
}