class AggregatingLocalMasterReadinessResolver implements LocalMasterReadinessResolver {

    @Override
    public Flux<ReadinessStatus> observeLocalMasterReadinessUpdates() {
        return stream;
    }

    public  AggregatingLocalMasterReadinessResolver(List<LocalMasterReadinessResolver> delegates, TitusRuntime titusRuntime);

}