反应Spring单声道和doOnNext

Question

我在我的项目中使用了spring-boot-starter-webflux、ractor-test和spring-boot-starter-test 2.0.0.m7。在我的RepositoryInMemory.Class中有一个List ，您可以通过savename(mono name) 方法添加字符串值。还可以询问通过getAllNames()方法添加到列表中的所有值。问题是如何测试RepositorYinMemory.Class？我有RepositorYinMemoryTest.Class，但它似乎不起作用，因为List 返回的总是0。我知道问题是RepositorYinMemory.Class中的DoonNext方法，但我不知道原因和如何解决它。有人知道我应该如何创建一个有效的Junit测试用例吗？

package com.example

import java.util.ArrayList;
import java.util.List;

import org.springframework.stereotype.Repository;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@Repository
public class RepositoryInMemory {

    private final List<String> names = new ArrayList<>();

    public Flux<String> getAllNames() {
        return Flux.fromIterable(names);
    }

    public Mono<Void> saveName(Mono<String> name) {
        return name.doOnNext(report -> names.add(report)).then();
    }
}

package com.example

import static org.junit.Assert.assertEquals;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import reactor.core.publisher.Mono;

@RunWith(SpringRunner.class)
@SpringBootTest
public class RepositoryInMemoryTest {

    @Autowired
    private RepositoryInMemory repository;

    @Test
    public void addDataToList_ShouldReturnOne() {
        Mono<String> name = Mono.just("Example Name");
        repository.saveName(name);
        int count = Math.toIntExact(repository.getAllNames().count().block());
        assertEquals(1, count);
    }
}

Answer 1

为了便于将来的读者澄清，请使用subscribe()而不是block()。因为block()实际上会阻塞线程，直到接收到下一个信号，这是违反异步概念的。

如果确实要切换回同步流，请使用block()。