Spring WebFlux类型与Kotlin toMono（）不匹配

Question

我收到以下警告：

Type mismatch.
Required: Any
Found: Customer?

当尝试在可空的客户实例上调用toMono（）方法时：

@Service
class CustomerServiceImpl @Autowired constructor(
        val customers: ConcurrentHashMap<Int, Customer>
) : CustomerService {
    override fun getCustomer(id: Int): Mono<Customer?> {
        return customers[id].toMono()
    }
}

客户服务：

interface CustomerService {
    fun getCustomer(id: Int): Mono<Customer?>
}

AppConfig：

@Configuration
class AppConfiguration {
    companion object {
        val initialCustomers: Array<Customer> = arrayOf(
                Customer(1, "Jerry"),
                Customer(2, "James"),
                Customer(3, "John")
        )
    }

    @Bean
    fun createCustomers() = ConcurrentHashMap<Int, Customer>(
            initialCustomers.associateBy(Customer::id)
    )
}

当我将CustomService接口中的返回类型定义为非空客户实例（： Mono




Answer 1

似乎＜code＞是单声道。JustoEmpty（）是我在这里寻找的，仅供参考。这似乎解决了可空对象的问题。

Answer 2

匿名用户

您似乎正在使用的 toMono（） 扩展定义如下：

fun <T : Any> T.toMono(): Mono<T> = Mono.just(this)

因为< code>T : Any，所以接收方不能为空。

我猜你需要这样的扩展:

fun <T : Any?> T.toMono(): Mono<T> = Mono.justOrEmpty(this)

声明:我甚至没有测试这是否编译。