代码之家 › 专栏 › 技术社区 › Mohammed Housseyn Taleb

java合并两个无重复的通量

reactor spring-webflux flux java

Mohammed Housseyn Taleb · 技术社区 · 7 年前

我有两个通量,我想合并它们以避免重复。我该怎么做?

Flux<Tweet> remoteTweets = Flux.just(
        new Tweet("tag1",new TweetID("text","name"),"userimage","country","place"),
        new Tweet("tag2",new TweetID("text","name"),"userimage","country","place")
);

Flux<Tweet> localTweets = Flux.just(
        new Tweet("tag1",new TweetID("text","name"),"userimage","country","place")
);

把这两个结合在一起会让我 tag 1, tag1, tag2 ,但我想 tag1, tag2 .

顺序并不重要。

1 回复 | 直到 7 年前

Ricard Kollcaku 7 年前

你可以这样做

     SpringApplication.run(BackendApplication.class, args);
  String[] strings = {"a","b","c"};
    Flux.merge(Flux.fromArray(strings),Flux.fromArray(strings))
            .distinct()
            .map(s -> {
                System.out.println(s);
                return s;
            }).subscribe();

但在Tweet对象中,您需要覆盖equals和hashcode

如果您使用的是intellij,请尝试alt+insert并单击equal和hashCode

推荐文章

testtt · 微服务REST调用和数据库事务

2 年前

Hamza Rouijel · Spring WebFlux thymelaf错误:无法解析名称为“index”的视图

2 年前

Chaitanya · 无法将Flux消息发送到模拟ReactorNettyWebSocketClient

2 年前

lightningbolt6 · Spring Boot WebClient-URL中的基本身份验证(用户名和密码)(401)

3 年前

user955165 · 为Webflux设置maxInMemorySize后拒绝连接

3 年前

Nicolas Sagala Beaucage · 带有路由器功能的Spring Boot 3 WebFlux无法从json反序列化Record

3 年前

C-Otto · 使用Mono.fromSupplier进行长期运行的map与flatMap

3 年前

fel3180 · 如何使用EnableWebFluxSecurity解决401未经授权的问题

3 年前

Jaime · 如何修复“服务器端请求伪造”强化Java

3 年前

Shubham Pratap Singh · TraceId/SpanId未在带有Sleuth的webflux应用程序中的flux doOnNext lambda块内打印

3 年前