@Override
    public void onCompleted() {
        for (StreamObserver<T> observer : observers) {
            try {
                observer.onCompleted();
            } catch (Exception t) {
                LOG.error("Exception in composite onComplete, moving on", t);
            }
        }
    }
CompositeStreamObserver of.

@param observers        observers
@param completeObserver completeObserver
@param <T>              t
@return CompositeStreamObserver compositeStreamObserver
shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-grpc/src/main/java/org/apache/shenyu/plugin/grpc/proto/CompositeStreamObserver.java