如何将List<Mono<String>>组合成一个大字符串？
将List<Mono<String>>组合成一个大字符串的方法是使用Mono.zip操作符。Mono.zip可以将多个Mono对象的结果合并为一个元组，然后可以对合并后的元组进行进一步处理。
下面是一种可能的实现方式：
import reactor.core.publisher.Mono;
import reactor.core.publisher.Flux;
public Mono<String> combineStrings(List<Mono<String>> monos) {
return Mono.zip(monos, objects -> {
StringBuilder sb = new StringBuilder();
for (Object obj : objects) {
sb.append(obj.toString());
}
return sb.toString();
});
}
public Mono<String> exampleUsage() {
List<Mono<String>> monos = new ArrayList<>();
// 添加要组合的 Mono 对象到列表中
monos.add(Mono.just("Hello"));
monos.add(Mono.just(" "));
monos.add(Mono.just("World"));
return combineStrings(monos);
}在这个示例中，combineStrings方法接受一个List<Mono<String>>参数，使用Mono.zip将所有的Mono对象合并为一个元组。然后通过遍历元组中的对象，并将它们追加到一个StringBuilder对象中，最后返回合并后的字符串。
你可以在你的代码中使用exampleUsage方法作为示例，传入你要组合的Mono对象列表，并订阅返回的Mono对象以获取最终的合并字符串。
注意：以上示例使用了 Reactor 库中的Mono和Flux对象，这是一种基于响应式编程的库，用于异步处理。你可以根据自己的项目需求选择适当的库或方法来实现这个功能。
相关·内容
我已经创建了一个String Monos List<Mono<String>> myList的列表。现在我需要将它们连接在一个大字符串中。 当我初始化StringBuilder并异步更新它时，可能会返回空行。 //method body....
StringBuilder builder = new StringBuilder();
myList.forEach {
mono ->
mono.map{ str -> builder.append(str)}
}
return builder.toString() //<- is
浏览 47提问于2019-06-20得票数 1
回答已采纳
如何将Flux< Employe>转换为Mono< Customers > object？ Flux< Employe> empFlux = getService()；//返回员工列表{私有字符串id；私有字符串信息；} //需要将empFlux数据转换为Mono< Customers> 公共类CusData { private String id;
private String dept;
private String info;
public String getId() {
return id;
} } 公共类客户{ pr
浏览 45提问于2019-10-16得票数 0
我是反应堆项目的新手。我有一个问题，如何将单声道添加到单声道？(我知道我可以使用Mono.block方法从单声道获取字符串，但我想学习正确的反应方式，所以Mono.block不被接受。)
import java.util.ArrayList;
import java.util.List;
import reactor.core.publisher.Mono;
public class Classroom {
private Mono<List<String>> classroom = Mono.just(new ArrayList<String>
浏览 31提问于2021-09-26得票数 0
没有几个问题，但答案非常具体的一些代码。
一般情况下，如何将Mono流转换为Flux
List<Mono<String> listOfMono = stream()
.map( s -> { do something and return Mono<String> } )
.collect(Collectors.toList());
如何将listOfMono对象转换为Flux<String>
浏览 2提问于2021-05-05得票数 4
回答已采纳
我正在尝试调用微服务应用程序中的外部服务，以便在启动其他计算之前并行地获取所有响应并组合它们。我知道我可以对每个Mono对象使用块()调用，但这将违背使用反应性api的目的。是否有可能并行启动所有请求并在某一时间点将它们合并。
示例代码如下所示。在这种情况下，在实际响应出现之前，“已完成”打印。我也知道订阅呼叫是非阻塞的。
我想要“完成”打印后，所有的回复已经收集，所以需要某种阻塞。但是，不希望阻止每个请求。
final List<Mono<String>> responseOne = new ArrayList<>();
IntStream.ran
浏览 3提问于2019-10-17得票数 4
回答已采纳
使用弹簧5，与反应堆，我们有以下需要。
Mono<TheResponseObject> getItemById(String id){
return webClient.uri('/foo').retrieve().bodyToMono(TheResponseObject)
}
Mono<List<String>> getItemIds(){
return webClient.uri('/ids').retrieve().bodyToMono(List)
}
Mono<RichResonseObjec
浏览 3提问于2017-11-20得票数 6
回答已采纳
我的REST控制器方法应该返回Mono，它必须由2个并行请求构建到另一个web服务，并处理它们的响应，其中一个请求返回Mono，另一个请求返回Flux。
如何将单组分和通量的反应结合起来处理？
模型：
@Document
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ClassModel {
@Id
private String id;
private String roomNr;
private String className;
private String teacherId;
浏览 0提问于2019-08-29得票数 0
回答已采纳
我正在尝试将这个方法转换成一个反应性的方法
@GetMapping(RestConstants.BASE_PATH_AUDIENCE + "/link")
public List<String> users () {
List<String> list= new ArrayList<>();
MongoCollection mongoCollection = mongoTemplate.getCollection("collection");
DistinctIterable distinctItera
浏览 1提问于2022-01-27得票数 1
回答已采纳
1回答
我正在做一项任务，我必须将Mono的列表缩减为一个Mono。
fun isValid(val: Int): Mono<Boolean> {
return Mono.just(true)
}
fun checkValue(): Mono<Boolean> {
val times = listOf(5, 10)
return times.map{
isValid(it)
}.reduce()
}
有人能帮我把Mono的单子减少到一个单子吗？
浏览 20提问于2022-09-26得票数 0
回答已采纳
2回答
如何将RenderTargetBitmaps列表合并为单个大型RenderTargetBitmap？
我通过渲染多个视觉效果创建了一个RenderTargetBitmaps列表。然后所有这些RenderTargetBitmaps需要组合成一个大的纹理图集(精灵工作表)。
浏览 6提问于2010-11-16得票数 0
回答已采纳
2回答
所以我很难找到不同类型的电话号码：
它们可以采用以下形式：
+xx xx xxxxxxxx - /[+][0-9]{2}\s[0-9]{2}[0-9]{8}/
xxxx xxxxxx - /[0-9]{4}\s[0-9]{6}/
xxxxx xxxxxx - /[0-9]{5}\s[0-9]{6}/
xxxxxxxxxxx - /[0-9]{11}
+xx xxxxxxxxxx - / [+][0-9]{2}\s[0-9]{10}
xxxx xxxxxxxxxx - /[0-9]{4} \s0-9]{10}/
我为每个表达式编写了正则表达式，但不确定如何将其组合成一个大表
浏览 1提问于2018-11-05得票数 1
回答已采纳
我正在编写一个简单的get方法来从API URL检索评论。API将json数据作为字符串返回。返回Mono<Object>会抛出错误。请在下面找到HTTP响应。 {
"timestamp": "2019-02-05T11:25:33.510+0000",
"path": "Some URL",
"status": 500,
"error": "Internal Server Error",
"message": &
浏览 77提问于2019-02-05得票数 6
回答已采纳
1回答
所以我在一个文件夹里有一堆json文件，我想把它们合并成一个大的json文件。
所以我知道你可以这样做，但我不确定如何将它添加到循环中，这样它就会一直加到1上。
var jObject1 = // Your first json object as JObject
var jObject2 = // Your second json object as JObject
jObject1.Merge(jObject2);
下面是一些示例数据
我已经创建了类来对对象进行建模
但我面临的问题是，我不知道如何将它们合并成一个大文件，我想使用foreach，有点像这样
foreach (var fi
浏览 1提问于2020-02-16得票数 0
2回答
我一直习惯于阻止编程和在Spring框架中工作。最近，我考虑学习反应性编程。我对如何将以前的逻辑转换成一种新的风格充满了怀疑。
请参见以下处理(伪码)：
public Mono<List<String>> a() {
// 1...
List<String> strings = new ArrayList<>();
for (int i = 0; i < 100; i++) {
strings.add("hello " + i);
}
Mono<List<S
浏览 19提问于2022-11-05得票数 3
如何将Monos列表组合到单个Mono。现在，我打电话给5家服务，其中2家成功，但其中3家可能失败，我想了解所有失败和成功的情况。我试过使用Mono.zipdelayError，但它不是那样工作的。每当出现错误时，就会出现我的资源异常处理程序。
为了便于了解，我公开了一个rest，它将在内部调用多个返回monos的服务，我必须将这些调用的结果合并到一个Mono中。
Mono<String> error = Mono.error(new RuntimeException());
error.onErrorResume(throwable-> Mono.just(
浏览 0提问于2018-09-21得票数 0
如何将这样的字符串：'20P20P20P20‘变成这样的列表: 20、P、20、P、20、P、20
my_string = '20P20P20P20'
list_of_steps = list(my_string)
for step in list_of_steps:
if step.isdigit():
new_map.append(int(step))
else:
new_map.append(step)
它变成了一个数字，但是如何将相邻的数字连接成一个数字呢？
浏览 2提问于2022-02-04得票数 0
我有以下模式：
class Person {
List<Address> addresses;
}
我使用ReactiveMongoRepository来检索Mono。
public interface PersonRepository extends ReactiveMongoRepository<Person, String>{
}
但是，我无法找到一种方法来将地址添加到人的地址中，并返回给定地址的Mono。这是我想要达到的目标的签名：
Mono<Address> addAddress(Address address)
下面是我在没有反应堆的情况
浏览 0提问于2019-07-16得票数 0
回答已采纳
1回答
链式反应组件调用
、、、
我有一个具有返回反应性类型Mono<?>的方法的以下对象列表
interface GuyWithReactiveReturnTypeMethod {
Mono<String> execute();
}
class ReactiveGuysInvocator {
Mono<String> executeAllGuys(List<GuyWithReactiveReturnTypeMethod> guysToInvoke) {
???
}
}
我需要逐个引用所有的人(n的结果是n+1的guy论点)，但我不知
浏览 2提问于2020-05-13得票数 1
回答已采纳
5回答
假设我有下一节课。
MyClass<T>
{
public void MyMethod(T a, List<T> b, List<Tuple<T, string>> c) {}
}
我可以获得该方法的参数类型如下
Type testType = typeof(MyClass<>);
MethodInfo myMethodInfo = testType.GetMethod("MyMethod");
Type[] paramTypes = myMethodInfo.GetParameters().Select(pi
浏览 3提问于2012-11-20得票数 4
回答已采纳
我正在尝试使用JAVA web-flux创建一个POST API。在这个应用程序接口中，我想创建一个字符串列表，并进行一个数据库调用以获取Mono<List>作为响应，但是当我试图使用block()将Mono<List>转换为简单的列表对象时，我得到了以下响应： {
"code": 500,
"message": "block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-nio-8&#
浏览 404提问于2020-12-31得票数 0
回答已采纳
如何将以下代码转换为Mono for Android代码？
ArrayAdapter<String> adapter = new ArrayAdapter<String>(this, R.layout.list_item, countries);
textView.setAdapter(adapter);
我找不到".setAdapter“
谢谢,
浏览 1提问于2011-06-19得票数 1
回答已采纳
我有一个Mono的列表，有些完成了一些失败：
Mono<String> success1 = Mono.just("hello");
Mono<String> success2 = Mono.just("world");
Mono<String> error1 = Mono.error(new IllegalArgumentException("error1"));
Mono<String> error2 = Mono.error(new IllegalArgumentException("
浏览 2提问于2021-02-21得票数 0
回答已采纳
1回答
我尝试用spring云网关开发api，但这对我来说并不容易。
我的“微型服务A”还一台Mono。此对象包含id "Object B“的列表，我的"microservice B”返回一个Flux
在我的api网关中，如何将微服务的结果聚合到一个Mono中？
@Service
public class ServiceAClient {
private final WebClient webClient;
public ServiceAClient(WebClient.Builder builder) {
this.webClient = buil
浏览 13提问于2022-06-17得票数 0
回答已采纳
1回答
我正在尝试使用Duplicati API来恢复单个文件。
关于场景的：全部运行在linux上，所以它是用mono编译的。我的备份包含两个源文件夹，所以如果我运行Interface.ListSourceFolders()，就会得到一个由两个数组组成的数组。
想要的结果：我想从备份中恢复一个文件(或文件夹)
当前结果:如果我运行下面的代码，它会将所有备份的文件(所以文件夹1和文件夹2)还原到//Comment1的路径中。
List<string> files = new List<string>();
files.Add("path"); //Comm
浏览 7提问于2015-08-03得票数 0
回答已采纳
1回答
我有一个返回Mono<Result>的规则列表，我需要执行它们，并返回另一个带有每个函数的结果的Mono列表。
Mono<List< Rule>>到Mono<List< RuleResult>>
我有这个，但阻止执行对我来说是不正确的：
List<Rule> RuleSet
...
Mono<List<RuleResult>> result= Mono.just(RuleSet.stream().map(rule -> rule.assess(object).block()).collect(
浏览 8提问于2020-07-23得票数 2
回答已采纳
2回答
假设我有一个类
Class Person {
String name;
String uid;
String phone;
}
我正试着按全班的所有字段分组。如何使用JAVA 8中的并行流来转换
List<Person> into Map<String,Set<Person>>
其中，映射的键是类中每个字段的值。以下示例按单个字段分组，如何将类的所有字段组合成单个Map？
ConcurrentMap<Person.Sex, List<Person>> byGender =
roster
.parallelStrea
浏览 6提问于2017-12-16得票数 7
回答已采纳
1回答
我正在尝试将一个大的xml文件拆分为几个较小的文件。我找到了一个解决方案，将每个节点拆分为它自己的文件：
awk '/<mono/{close("row"count".xml");count++}count{f="row"count".xml";print $0 > f}' file.xml
上面的代码匹配每个"mono“节点，并将其输出到文件名row{rownumber}.xml。如何将每20个匹配项打印到一个文件？
浏览 4提问于2011-03-07得票数 0
回答已采纳
1回答
下面的函数将检索字符串列表。在合并过程中，我希望将输出写入CSV文件，而不是打印输出。 List<Mono<Device>> list1 = page.get().map(device -> webClient.post()
.uri(uri)
.header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.header(HttpHeaders.ACCEPT, MediaType.APPLICA
浏览 20提问于2021-04-07得票数 0
回答已采纳
2回答
我试图从请求体中获取简单的字符串，但仍然会出现错误。
处理程序：
@RestController
public class GreetingHandler {
public Mono<ServerResponse> hello(ServerRequest request) {
String contentType = request.headers().contentType().get().toString();
String body = request.bodyToMono(String.class).toString();
浏览 0提问于2019-02-05得票数 4
回答已采纳
如何将Flux<MyObject>直接转换为Mono<List<MyObject>>？
我正在寻找来自RxJava的等价物Single<List<MyObject>> single = observable.toList()。
使用阻塞操作符，我可以这样做：
val just: Mono<List<MyObject>> = Mono.just(flux.toIterable().toList())
但它是在声明的时候执行的，这看起来是不正确的。
浏览 1提问于2017-05-18得票数 3
回答已采纳
我有一个XML要解析。虽然我能够获取它们，但我不能用分隔符分隔它们以供进一步处理。请给我建议。我的代码如下
use XML::LibXML;
my $filename = 'Test.xml';
my $parser = XML::LibXML->new();
my $dom = $parser->parse_file($filename);
my $root = $dom->documentElement();
my $xpc = XML::LibXML::XPathContext->new($root);
foreach my $id ($xp
浏览 3提问于2015-01-07得票数 1
回答已采纳
1回答
我正在尝试实现以下简单的命令式逻辑： boolean saveImperative(final List list) {
final String existingList = readByNameImperative(list.getName());
if (Objects.isNull(existingList)) {
templateSaveImperative(existingList);
return true;
} else {
templateSaveImperative(existingList);
浏览 27提问于2020-01-17得票数 1
回答已采纳
1回答
我有一个输入值，需要传递一个Mono链来处理它。下一个输入是前一个结果的依赖项。
public class MonoMapReplaceTest {
public static void main(String[] args) {
String originStr = "hello";
List<String> rules = List.of("+1", "+2", "+3");
List<Mono<String>> monos = ne
浏览 4提问于2022-10-19得票数 0
在sudo apt get update之后显示--不确定需要修复什么：
Running hooks in /etc/ca-certificates/update.d...
Updating Mono key store
Mono Certificate Store Sync - version 6.12.0.139
Populate Mono certificate store from a concatenated list of certificates.
Copyright 2002, 2003 Motus Technologies. Copyright 2004-2008 Novel
浏览 0提问于2021-05-01得票数 1
如何将Monos的贴图转换为Mono，并发出包含每个值的map？ private Mono<Map<Long, String>> convertMonoMap(Map<Long, Mono<String>> monoMap) {
// TODO what comes here?
}
@Test
public void testConvert() {
Map<Long, Mono<String>> input = Map.of(1L, Mono.just("1"), 2L,
浏览 77提问于2021-08-16得票数 2
回答已采纳
由于dotnet核心3预览9，我面临一个调用从JavaScript传递一个大字符串的dotnet方法的问题。
代码值超过一千字，因此下面的代码片段再现了这个问题。它在length = 1 * mb时工作，但当length = 2 * mb时失败。
@page "/repro"
<button onclick="const mb = 1024 * 1024; const length = 2 * mb;console.log(`Attempting length ${length}`); DotNet.invokeMethod('@GetType().Ass
浏览 2提问于2019-09-14得票数 3
回答已采纳
1回答
我有一个夹子里面有地板文件。
如何将它们全部读取并转换成一个大的txt文件？
我正在使用parquetjs库读取1个文件：
(
async () => {
// create new ParquetReader that reads from 'fruits.parquet`
let reader = await parquet.ParquetReader.openFile('fruits.parquet');
// create a new cursor
let cursor = read
浏览 0提问于2019-03-04得票数 1
回答已采纳
关于webflux reactive存储库的小问题，特别是关于Flux saveAll(Iterable Var1)和Flux saveAll(Publisher Var1)的方法； 为了进行比较，我写了以下内容： @Controller
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class);
}
@Autowired
private
浏览 119提问于2020-09-01得票数 1
回答已采纳
1回答
如何将</in>添加到每行的末尾？
字符串包含：
<ch>13</ch><in>Item 13(mono)
<ch>14</ch><in>Item 14(mono)
<ch>15</ch><in>Item 15(mono)
浏览 0提问于2011-09-25得票数 0
回答已采纳
响应：
[
{
"version": "1.0",
"content": [
"12345",
"67076",
"123462",
"604340",
"1331999",
"1332608",
"1785581",
]
}
]
代码：
Mono<List<String>> mp = webClient.get().uri(accoun
浏览 0提问于2019-06-15得票数 4
回答已采纳
一个类UploadService从REST接收一个FilePart，表示下面JSON的内容。
目标是从这个Mono<String>返回一个FilePart来构建一个JSONObject。
这是发布的JSON:
{
"machineId" : "7",
"printJobId" : "123",
"timeStampStartPrintJob" : "10:23:15,253",
"timeStampEndPrintJob" : "12:50:16,577"
浏览 5提问于2021-04-01得票数 1
请看下面代码的注释部分中嵌入的我的问题- // This should return a list of all ids and their name and status info, e.g. as json
public Mono<ServerResponse> f1(String originalId) {
// this gives list of ids which are comma separated
Mono<String> ids = f2(originalId);
ids.flatMapIterable(li
浏览 166提问于2021-06-27得票数 0
回答已采纳
我是WebFlux/反应堆的新手，我很难思考如何编写这段代码。基本上，我有一个Flux，它有一个嵌套的列表foo和一个Mono栏，我只想返回包含在bar中的foo中的项。
// these two lines are representations of what the data looks like
Flux<CategoryModel> foo = { Permissions = [ "UserRole1"] } // List<String>
Mono<Set<String>> bar = [ "UserRole1
浏览 1提问于2021-03-25得票数 2
回答已采纳
1回答
我正在使用spring来消耗彼此的服务，并试图将结果添加到不同输入组合的列表中。但是有一点我无法订阅并将结果转换成列表
该方法将获取Map并遍历映射，并使用不同的输入组合调用另一个服务。
但是无法在getAPrice()中完成我想要的：
输入：
公共Mono<List> getAPrice() {返回Mono.create(monoSink ->{ getActiveMonths() .entrySet().stream() .flatMap) .flatMap(e->getContractPrice(e.getKey()，e.getValue()) /*卡在这里，
浏览 2提问于2019-10-31得票数 0
回答已采纳
我是否可以将Mono<List<Item>>数据源的列表组合成一个包含所有项的Mono<List<Item>>，而不需要阻塞？
在我的JDK 9 Spring 2和Lombok分散收集应用程序中，这个阻塞版本可以工作：
private Mono<List<Item>> gather(List<Mono<List<Item>>> data) {
return Mono.just( data.stream().map(m -> m.block())
浏览 0提问于2018-01-25得票数 4
我有一个Mono<List<PojoA>>对象。我需要迭代PojoA and列表，形成一个新的List<String>
public List<String> getImageList() {
Mono<List<PojoA>> pojoAListMono = someMethod();
List<String> list = new ArrayList<String>();
pojoAListMono.flatMapMan
浏览 3提问于2020-09-29得票数 0
回答已采纳
2回答
映射在WebFlux中的正确使用
、、、、
public Mono<EmailDto> getEmail() {
Mono<EmailService> emailService = ReactiveSecurityContextHolder.getContext()
.map(securityContext -> (Principal) securityContext.getAuthentication().getPrincipal())
.map(principal -> emailServiceSelector.sel
浏览 3提问于2020-07-20得票数 1
回答已采纳
我的程序服务提供了一些返回Mono<Void>的删除方法，例如：fun delete(clientId: String) : Mono<Void>
在调用.delete("x")之后，我想向下游传播clientId以执行其他操作：
userService.get(id).map{ user ->
userService.delete(user.id) //This returns Mono<Void>
.map {
user.id //Never called!!!
}
.ma
浏览 7提问于2019-08-09得票数 3
回答已采纳
1回答
相关函数的时间复杂度
、、、
我有这个方法
public static void primeSort( String[] list, HashMap< Integer, ArrayList< String >> hm ){
for( int x=0; x<list.length; x++ ){
if( list[ x ] == null ) continue;
String curX = list[ x ];
int hashX = primeHash( curX );
hm.put( hashX, new ArrayList( Arr
浏览 0提问于2015-10-30得票数 1
如何使用单次嵌入调用创建泛型列表对象？我可以得到List的MonoClass：
MonoClass* list = mono_class_from_name(mscorlibimage,
"System.Collections.Generic", "List`1");
我在文档里看到
mono_class_from_generic_parameter(MonoGenericParam*...)
但我不知道在哪里以及如何获得MonoGenericParam。或者我需要为mono_class_from_name构造一个有效的名称？我认为这可能会慢一点，但我
浏览 9提问于2013-07-13得票数 6
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
