以编程方式断言WebFlux流的最佳方式是什么

Question

所以我们假设我们有这样的东西：

public class SomeService {
...
public Flux<String> getStringsFromWebServer() {
return webClient.get()
.uri(this::generateSomeUrl)
.retrieve()
.bodyToMono(SomePojo.class)
.map(SomePojo::getStringList)
.flatMapMany(Flux::fromIterable);
}

写这样的测试有意义吗：

void getStringsFromWebServer_shouldParseInOrderOfReceivingStrings() {
// given
// I have mocked up a WebClient, that is wired up to a Mocked Web Server
// I am preloading the Mocked Web Server with this JSON
String jsonStrings = "{'stringList': ['hello1', 'hello2', 'hello3']}"
mockWebServer.enqueue(new MockResponse().setResponseCode(200))
.addHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.setBody(jsonStrings);
// when
Flux<String> result = someService.getStringsFromWebServer();
// then
StepVerifier.FirstStep<String> fluxStep = StepVerifier.create(result);
for (int i = 1; i < 4; i++) {
String expectedInput = String.format("hello%d", i);
fluxStep.assertNext(someString -> assertEquals(expectedInput, someString));
}
fluxStep.verifyComplete(); 
}

这就是通过编程断言Flux返回的顺序的方式吗？

我是不是用assertNext通量法做了什么坏事？我的意思是，从这个意义上说，我总是提供有序的数据，所以我假设fromIterable将按照spring引导应用程序接收到的顺序从该列表中消费。

感觉我在这里违反了某种原则。。。我的意思是它有效。。。

Answer 1

Meh整理了一下。

因此有了expectNext方法：

https://www.baeldung.com/flux-sequences-reactor

在这里，你可以预先生成你的列表，然后断言这样的东西：

List<String> expectedStrings = Arrays.asList(
"hello1", "hello2", "hello3"
);
...
StepVerifier.create(result)
.expectNextSequence(expectedStrings)
.verifyComplete();

编辑：显然我要等几天才能把我自己的问题标记为答案？