如何通过Spring WebFlux Reactive方法在处理函数中使用Mono和Flux

我的模型看起来像这样。


@Document

public class PlanDetails {


    @Id

    private String id;

    private String name;

    private Double balance;

    private Double internet;

    private Date date;


    --> //String of id's basically.

    private List<String> members;


    public PlanDetails(){}


    public PlanDetails(String id, String name, Double balance, Double internet, Date date, List<String> members){

        this.id = id;

        this.name = name;

        this.balance = balance;

        this.internet = internet;

        this.date = date;

        this.members = members;

    }


    public String getId() {

        return id;

    }


    /* Getter setters ommited for brevity */

这是我的处理程序类,用于处理我的功能端点。


package com.startelco.plandetailsapi.handler;


import com.startelco.plandetailsapi.model.PlanDetails;

import com.startelco.plandetailsapi.repository.PlanRepository;

import org.springframework.http.HttpStatus;

import org.springframework.stereotype.Component;

import org.springframework.web.reactive.function.BodyInserters;

import org.springframework.web.reactive.function.server.ServerRequest;

import org.springframework.web.reactive.function.server.ServerResponse;

import reactor.core.publisher.Flux;

import reactor.core.publisher.Mono;


import static org.springframework.http.MediaType.APPLICATION_JSON;

@Component

public class PlanDetailsHandler {


    private PlanRepository repository;



    public PlanDetailsHandler(PlanRepository repository){

        this.repository = repository;

    }


    //Get All Users

    public Mono<ServerResponse> getAllUsers(ServerRequest request){

        Flux<PlanDetails> users = repository.findAll();


        return ServerResponse.ok()

                .contentType(APPLICATION_JSON)

                .body(users,PlanDetails.class);

    }


问题:getMemberDetails重新使用先前编写的函数时,响应式编码方式是getUserDetails.什么?


慕的地10843
浏览 521回答 2
2回答
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java