@Override
    public void validate(ChangeContext context) {
        context.previousModel().getContentClusters().forEach((clusterName, currentCluster) -> {
            ContentCluster nextCluster = context.model().getContentClusters().get(clusterName);
            if (nextCluster != null) {
                if ( ! nextCluster.getSearch().hasStreaming()) return;
                if (currentCluster.getSearch().getSearchCluster() != null && nextCluster.getSearch().getSearchCluster() != null) {
                    validateStreamingCluster(currentCluster, currentCluster.getSearch().getSearchCluster(),
                                             nextCluster, nextCluster.getSearch().getSearchCluster())
                            .forEach(context::require);
                }
            }
        });
    }
Validates the changes between all current and next streaming search clusters in a Vespa model.

@author geirst
config-model/src/main/java/com/yahoo/vespa/model/application/validation/change/StreamingSearchClusterChangeValidator.java