[仅在源更新时才从Flux 发布到Flux >

Question

我想发布密钥列表，但仅在修改密钥时才发布。

使用以下命令，即使没有任何更改，它也会以无限循环的方式发布值

    RedisReactiveCommands<String, String> commands = connection.reactive();
    return commands
            .keys(String.format(AWAITING_USER_KEY_FORMAT, "*")) // returns Flux<String>
            .collectList() // returns Mono<List<String>>
            .repeat(); // returns Flux<List<String>>

仅在列表更改后如何发布？

Answer 1

distinctUntilChanged

：“禁止由Observable发出的重复项”