如何在Micronaut中使用reactive MongoDB？

import io.micronaut.data.annotation.Repository;
import io.micronaut.data.repository.reactive.RxJavaCrudRepository;

@Repository
public interface UserRepository extends RxJavaCrudRepository<User, String> {
    // 定义与用户相关的操作方法
}

import io.micronaut.data.annotation.Id;
import io.micronaut.data.annotation.TypeDef;
import io.micronaut.data.model.DataType;

@TypeDef(type = DataType.OBJECT)
public class User {
    @Id
    private String id;
    private String name;
    // 其他属性和方法
}

import io.reactivex.Flowable;
import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Get;
import io.micronaut.http.MediaType;

@Controller("/users")
public class UserController {
    private final UserRepository userRepository;

    public UserController(UserRepository userRepository) {
        this.userRepository = userRepository;
    }

    @Get(produces = MediaType.APPLICATION_JSON)
    public Flowable<User> getAllUsers() {
        return userRepository.findAll();
    }
}