in 3-extensions/protocol/dubbo-samples-triple/src/main/java/org/apache/dubbo/sample/tri/interop/client/GrpcGreeterImpl.java [74:99]
public StreamObserver<GreeterRequest> cancelBiStream2(
StreamObserver<GreeterReply> responseObserver) {
Context.current().addListener(
context -> {
cancelResultMap.put("cancelBiStream2", true);
}
, MoreExecutors.directExecutor());
return new StreamObserver<GreeterRequest>() {
@Override
public void onNext(GreeterRequest data) {
responseObserver.onNext(GreeterReply.newBuilder()
.setMessage(data.getName())
.build());
}
@Override
public void onError(Throwable throwable) {
throwable.printStackTrace();
}
@Override
public void onCompleted() {
responseObserver.onCompleted();
}
};
}