I can't get query data about demo-reactive-mybatis HOT 11 CLOSED

public class UserAsyncHandlerImpl implements UserAsyncHandler {

    @Qualifier(value = "UserLoginService")
    @Autowired
    private UserLoginService loginService;

    /**
     * <pre>
     *     用户登录 handler
     *     用户登录对象为 UserDetails {username, password, scope, client_id, client_secret}
     * @success : 返回 {access_token, scope, expires_in, refresh_token}
     * @failed : 返回 UserLoginException
     * </pre>
     * @param request
     * @return Mono<ResultData<LinkedHashMap>>
     */
    @Override
    public Mono<ServerResponse> userLogin(ServerRequest request) {
        return request
                .bodyToMono(User.class)
                .flatMap(user -> ok().body(BodyInserters.fromObject(loginService.login(user))));
    }

    /**
     * @param request
     * @return
     */
    @Override
    public Mono<ServerResponse> userAddInfo(ServerRequest request) {
        return ok().body(BodyInserters.empty());
    }

    /**
     * @param request
     * @return
     */
    @Override
    public Mono<ServerResponse> courierAddInfo(ServerRequest request) {
        return null;
    }

    /**
     * @param request
     * @return
     */
    @Override
    public Mono<ServerResponse> userOrCourierUpdateInfo(ServerRequest request) {
        return null;
    }

}

public class UserLoginServiceImpl implements UserLoginService {

    private final WxUserMapper userMapper;

    public UserLoginServiceImpl(WxUserMapper userMapper) {
        this.userMapper = userMapper;
    }

    @Autowired
    private OAuthToken tokenFactory;

    /**
     * @param user
     * @return
     */
    @Override
    public Flux<ResultData<LinkedHashMap>> login(User user) {
        ResultData<LinkedHashMap> token = tokenFactory.init(user, getWxUser(user)).token().build();
        return Flux.just(token).zipWith(Flux.interval(Duration.ZERO)).map(Tuple2::getT1).publish();
    }

    /**
     * @param wxUser
     * @return
     */
    @Override
    public Mono<ResultData> register(WxUser wxUser) {
        return null;
    }

    @Override
    public Mono<WxUser> test(User user) {
        log.info("User info {}", user);
        return Flux.just(userMapper.login(user.getUsername())).singleOrEmpty().subscribeOn(Schedulers.elastic());
    }

    /**
     * 
     * @param user
     * @return
     */
    private WxUser getWxUser(User user) {
        return userMapper.login(user.getUsername());
    }
}