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

java合并两个无重复的通量

reactor spring-webflux flux java

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

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

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 回复 | 直到 6 年前

Ricard Kollcaku 6 年前

你可以这样做

     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

推荐文章

Filip T · 流量与全局变量(服务中)

7 年前

daGrevis · Typecheck createAction Redux助手

7 年前

Oleg V Karun · 通量:场。text+CKEditor在每个保存操作的后端添加新的空

7 年前

AndrewMcLagan · 重做:组织容器、组件、动作和减速器

8 年前

Jake Haller-Roby · 在Flux中,使用名为ActionCreator的通用组件是否更合适?

8 年前

Zahidur Rahman · 在使用基于反应的应用程序时,还原和回流的核心区别是什么?

8 年前

Rafael Korbas · 如何在react as文件中下载fetch响应

9 年前

Kethmar Salumets · Javascript Redux-如何通过id从store获取元素

9 年前

eltuza · React+Webpack:在何处配置REST端点

9 年前