如何在spring webflux中使用ReactiveQuerydslPredicateExecutor

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

<dependency>
    <groupId>com.querydsl</groupId>
    <artifactId>querydsl-jpa</artifactId>
</dependency>

@Entity
@Table(name = "users")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private String name;
    private Integer age;

    // getters and setters
}

public interface UserRepository extends ReactiveCrudRepository<User, Long>, QuerydslPredicateExecutor<User> {
}

@Service
public class UserService {
    private final UserRepository userRepository;

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

    public Flux<User> getUsersByPredicate(Predicate predicate) {
        return userRepository.findAll(predicate);
    }
}

@RestController
@RequestMapping("/users")
public class UserController {
    private final UserService userService;

    public UserController(UserService userService) {
        this.userService = userService;
    }

    @GetMapping
    public Flux<User> getUsers(@RequestParam(required = false) String name,
                               @RequestParam(required = false) Integer age) {
        QUser qUser = QUser.user;
        BooleanExpression predicate = qUser.isNotNull();

        if (name != null) {
            predicate = predicate.and(qUser.name.eq(name));
        }

        if (age != null) {
            predicate = predicate.and(qUser.age.eq(age));
        }

        return userService.getUsersByPredicate(predicate);
    }
}