开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

社区首页 >问答首页 >求反应流的排列

问求反应流的排列
EN

Stack Overflow用户

提问于 2019-02-06 18:26:25

回答 1查看 122关注 0票数 1

我有两个应该异步工作的反应性流。因此，我应该调用foo()函数，它将接受两个参数，并将与来自两个初始反应流的元素的所有可能排列一起调用。如果有任何异常发生在整个过程中，它应该使所有事情都失败。通过使用反应堆核心来实现这一点的最佳方法是什么？

示例：

    String[] aInitial = {"a","b","c"};
    String[] bInitial = {"0","1"};

    Flux<String> fluxA = Flux.fromArray(aInitial);
    Flux<String> fluxB = Flux.fromArray(bInitial);

    ...

    private void foo(String a, String b){
        System.out.println(a + ", " + b); 
    }

预期结果(顺序不重要)：

a，0 a，1 b，0 b，1 c，0 c，1

project-reactor

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-02-06 21:39:36

而不是在执行转换的方法中调用操作(在您的例子中是System.out.println)，而是将其分割成一个函数，它将两个元素组合在一起，另一个函数将数据操作组合在一起。

public static void main(String[] args) {

    String[] aInitial = {"a", "b", "c"};
    String[] bInitial = {"0", "1"};

    Flux<String> fluxA = Flux.fromArray(aInitial);
    Flux<String> fluxB = Flux.fromArray(bInitial);

    fluxA
            .flatMap(input1 -> fluxB.map(input2 -> foo(input1, input2)))
            .doOnNext(System.out::println)
            .blockLast();
}

private static String foo(String a, String b) {
    return a + ", " + b;
}

如您所见，我们遍历第一个通量，并使用第二个通量创建一个嵌套循环。

请注意，这将不适用于热通量，只有冷通量将在这里工作，因为我们需要重新订阅第二个通量的每一个元素从第一个发射。

票数 1

EN

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/54565433

复制

相关文章

C# 各种字符串格式

java https 网络安全

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/120407.html原文链接：https://javaforall.cn

全栈程序员站长

2021/12/27

6070

类型自定义格式字符串

String可能是使用最多的类型，ToString()则应该是大家使用得最多的方法了。然而它不应该仅仅是用来输出类型的名称，如果使用得当，它可以方便地输出我们对类型自定义的格式。本文将循序渐进地讨论ToString()，以及相关的IFormattable、IFormatProvider以及ICustomFormatter接口。

张子阳

2018/09/30

5860

PowerBI DAX 自定义格式字符串

python 编程算法 vba

PowerBI DAX 的格式化字符串并不是一个简单的话题，我们用一个篇章来介绍其中的规律。后续的内容会进一步扩展到复杂的应用中。

BI佐罗

2021/01/25

1.8K0

PowerBI 自定义格式字符串参考大全

这个参考暂时列出以上内容，如果您发现有什么自己写不出来的，可以留言，我们可以追加更新本列表。

BI佐罗

2021/02/12

6430

PowerBI 自定义格式字符串参考大全

C#判断字符串是否是有效的XML格式数据

xml 对象数据异常字符串

　　在try-catch语句块中，创建XmlDocument对象，并使用LoadXml方法加载xml字符串。如果没有异常，则说明xml字符串是有效的，返回true，反之为false。

追逐时光者

2023/04/08

1K0

C#使用ParseExact方法将字符串转化为日期格式

c#text txt 系统字符串

明志德道

2023/10/21

3520

C#使用ParseExact方法将字符串转化为日期格式

C#日期格式转换

DateTime dt = DateTime.Now; // Label1.Text = dt.ToString();//2005-11-5 13:21:25 // Label2.Text = dt.ToFileTime().ToString();//127756416859912816 // Label3.Text = dt.ToFileTimeUtc().ToString();//127756704859912816 // Label4.Text = dt.ToLocalTime().ToString(

欢醉

2018/01/22

1.9K0

C# 自定义类型通过实现IFormattable接口,来输出指定的格式和语言文化的字符串(例:DateTime)

在开发一些国际化的应用时,应用程序需要调用与当前线程不同的语言文化来格式化字符串.

郑小超.

2018/08/01

1.1K0

C# 自定义类型通过实现IFormattable接口,来输出指定的格式和语言文化的字符串(例:DateTime)

c# datetime 格式化

//c datetime 格式化 DateTime dt = DateTime.Now; Label1.Text = dt.ToString();//2005-11-5 13:21:25 Label2.Text = dt.ToFileTime().ToString();//127756416859912816 Label3.Text = dt.ToFileTimeUtc().ToString();//127756704859912816 Label4.Text = dt.ToLocalTime().ToSt

阿炬

2018/05/11

1.4K0

C#格式化输入数据为货币格式

c#double 变量对象数据

明志德道

2023/10/21

2110

java 获取字符串编码格式_输入字符串的格式要求

java https 网络安全

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至举报，一经查实，本站将立刻删除。

全栈程序员站长

2022/09/30

1.5K0

spark dataframe 数据转化为 json 或者自定义格式的字符串

文章大纲创建dataframe 官方的方法自定义格式创建dataframe import org.apache.spark.sql.types._ val schema = StructType(List( StructField("integer_column", IntegerType, nullable = true), StructField("string_column", StringType, nullable = true),

流川疯

2021/12/06

1.2K0

spark dataframe 数据转化为 json 或者自定义格式的字符串

C#将日期格式化为指定格式

c#datetime tostring 变量字符串

明志德道

2023/10/21

2350

java json字符串格式化_格式化字符串攻击

编程算法 json

大家好，我是架构君，一个会写代码吟诗的架构师。今天说一说java json字符串格式化_格式化字符串攻击,希望能够帮助大家进步!!!

Java架构师必看

2022/07/29

1.1K0

格式化字符串漏洞利用三、格式化字符串漏洞

编程算法网络安全安全

格式化字符串漏洞的通常分类是“通道问题”。如果二类不同的信息通道混合为一个，并且特殊的转义字符或序列用于分辨当前哪个通道是激活的，这一类型的漏洞就可能出现。多数情况下，通道之一是数据通道，它不会解析，只会复制，而另一个通道是控制通道。

ApacheCN_飞龙

2022/12/01

1.1K0

C#字符串截取

常用字符串截取 string str="123abc456"; int i=3; 1 取字符串的前i个字符 str=str.Substring(0,i); // or str=str.Remove(i,str.Length-i); 2 去掉字符串的前i个字符： str=str.Remove(0,i); // or str=str.Substring(i); 3 从右边开始取i个字符： str=str.Substring(str.Length-i); // or str=str.Remove(0,st

yaphetsfang

2020/07/30

2.3K0

字符串转时间格式

java https 编程算法网络安全 python

import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date;

全栈程序员站长

2022/08/22

1.1K0

logback自定义日志格式

java servlet 编程算法 http xml

然后在logback.xml配置文件中，定义自定义标签define name代表标签，class指向处理的类。在初始化时调用getPropertyValue()

全栈程序员站长

2022/08/15

8120

c# 导入导出excel表格式

c#使用代码导入excel时，当遇到纯数字且大于15位时会出现编码混乱（表现为科学计数法），要想呈现与excel表中纯数字格式和在数据库中呈现纯数字，操作如下：

wfaceboss

2019/04/08

1.6K0

c# 导入导出excel表格式

C# 字符串拼接

编程算法 c#

✅作者简介：人工智能专业本科在读，喜欢计算机与编程，写博客记录自己的学习历程。 🍎个人主页：小嗷犬的博客 🍊个人信条：为天地立心，为生民立命，为往圣继绝学，为万世开太平。 🥭本文内容：C# 字符串拼接 ---- C# 字符串拼接 1.通过加号拼接 2.字符串格式化 3.控制台打印拼接 ---- 1.通过加号拼接 C# 中，字符串没有相加的数学运算，但它可以通过加号+来进行字符串的拼接： using System; namespace ConsoleApplication { c

小嗷犬

2022/11/15

6750

相似问题

C#：自定义时区格式字符串

11

c#自定义日期类，字符串格式

13

列表C#中的自定义字符串格式

22

C#从字符串解析DateTime (自定义格式)

20

c#月份日历短日期字符串自定义格式

15

添加站长进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例