retrofit2 和 rxjava - 如何在 android 中组合两个依赖的网络调用

Question

我无法理解如何将两个网络调用链接在一起。我正在使用 retrofit2 和 rxJava。我正在使用 Yelp API，并且已经为我想要捕获的企业提供了一个 gson Pojo。但是业务的 api 调用不包括评论，所以在我获得业务后，我必须进行另一个网络调用才能获得评论（基于第一次调用的业务 id）。

所以我想要发生的事情如下： 1. 进行 api 调用以获取企业 ID（给定用户提供的搜索词）。 2. 完成后，我需要使用商家 ID 进行审核。

两者都是不同的 api 调用。

获取商家 ID 的调用如下所示：

https://api.yelp.com/v3/businesses/search?term=delis&latitude=37.786882&longitude=-122.399972

另一个获取评论的电话是这样的：

https://api.yelp.com/v3/businesses/molinari-delicatessen-san-francisco/reviews

所以第二次调用取决于第一次调用的数据。

在改造 2 中，我将以下设置为服务：

   @GET("v3/businesses/search")
Observable<Businesses> getBusinessesRx(
        @Query("term") String term,
        @Query("latitude") String latitude,
        @Query("longitude") String longitude);

@GET("v3/businesses/{id}/reviews")
Observable<Businesses> getReviewsRx(
        @Path("id") String businessID);

但请注意，我在两者中都使用了 Businesss pojo。不确定我是否可以这样做。 Businesses gson pojo 用于第一次调用（在＃1 中）以获取给定搜索词的企业组。但我不介意我是否可以为评论添加一个额外的字段以及如何填充它。这样，我的企业课程就可以对找到的每个企业进行评论。

我不确定如何在 RXjava 中启动它。我知道我需要一个平面图，但我对要使用的 POJO 以及如何使其工作感到有些困惑。这是在安卓设备上。

如果需要，我的业务 pojo 看起来像这样：

public class Businesses {

@SerializedName("businesses")
@Expose
private List<Business> businesses = new ArrayList<Business>();
@SerializedName("total")
@Expose
private Integer total;

/**
 * 
 * @return
 *     The businesses
 */
public List<Business> getBusinesses() {
    return businesses;
}

/**
 * 
 * @param businesses
 *     The businesses
 */
public void setBusinesses(List<Business> businesses) {
    this.businesses = businesses;
}

/**
 * 
 * @return
 *     The total
 */
public Integer getTotal() {
    return total;
}

/**
 * 
 * @param total
 *     The total
 */
public void setTotal(Integer total) {
    this.total = total;
}

}

我的业务 pojo（针对每个单独的业务）如下所示：

public class Business {

@SerializedName("image_url")
@Expose
private String imageUrl;
@SerializedName("id")
@Expose
private String id;
@SerializedName("name")
@Expose
private String name;
@SerializedName("location")
@Expose
private Location location;
@SerializedName("rating")
@Expose
private Integer rating;
@SerializedName("price")
@Expose
private String price;
@SerializedName("categories")
@Expose
private List<Category> categories = new ArrayList<Category>();
@SerializedName("phone")
@Expose
private String phone;
@SerializedName("review_count")
@Expose
private Integer reviewCount;
@SerializedName("coordinates")
@Expose
private Coordinates coordinates;
@SerializedName("url")
@Expose
private String url;

/**
 * 
 * @return
 *     The imageUrl
 */
public String getImageUrl() {
    return imageUrl;
}

/**
 * 
 * @param imageUrl
 *     The image_url
 */
public void setImageUrl(String imageUrl) {
    this.imageUrl = imageUrl;
}

/**
 * 
 * @return
 *     The id
 */
public String getId() {
    return id;
}

/**
 * 
 * @param id
 *     The id
 */
public void setId(String id) {
    this.id = id;
}

/**
 * 
 * @return
 *     The name
 */
public String getName() {
    return name;
}

/**
 * 
 * @param name
 *     The name
 */
public void setName(String name) {
    this.name = name;
}

/**
 * 
 * @return
 *     The location
 */
public Location getLocation() {
    return location;
}

/**
 * 
 * @param location
 *     The location
 */
public void setLocation(Location location) {
    this.location = location;
}

/**
 * 
 * @return
 *     The rating
 */
public Integer getRating() {
    return rating;
}

/**
 * 
 * @param rating
 *     The rating
 */
public void setRating(Integer rating) {
    this.rating = rating;
}

/**
 * 
 * @return
 *     The price
 */
public String getPrice() {
    return price;
}

/**
 * 
 * @param price
 *     The price
 */
public void setPrice(String price) {
    this.price = price;
}

/**
 * 
 * @return
 *     The categories
 */
public List<Category> getCategories() {
    return categories;
}

/**
 * 
 * @param categories
 *     The categories
 */
public void setCategories(List<Category> categories) {
    this.categories = categories;
}

/**
 * 
 * @return
 *     The phone
 */
public String getPhone() {
    return phone;
}

/**
 * 
 * @param phone
 *     The phone
 */
public void setPhone(String phone) {
    this.phone = phone;
}

/**
 * 
 * @return
 *     The reviewCount
 */
public Integer getReviewCount() {
    return reviewCount;
}

/**
 * 
 * @param reviewCount
 *     The review_count
 */
public void setReviewCount(Integer reviewCount) {
    this.reviewCount = reviewCount;
}

/**
 * 
 * @return
 *     The coordinates
 */
public Coordinates getCoordinates() {
    return coordinates;
}

/**
 * 
 * @param coordinates
 *     The coordinates
 */
public void setCoordinates(Coordinates coordinates) {
    this.coordinates = coordinates;
}

/**
 * 
 * @return
 *     The url
 */
public String getUrl() {
    return url;
}

/**
 * 
 * @param url
 *     The url
 */
public void setUrl(String url) {
    this.url = url;
}

}

Answer 1

我不确定我的理解是否正确，但从第一次通话开始，您会收到商家列表，而不是您需要审核的每个商家。如果是这样，您可以使用以下代码：

ApiService service = Retrofit.create(ApiService.class);
service.getBusinessesRx("delis", "37.786882", "-122.399972")
        .map(Businesses::getBusinesses)
        .flatMap(Observable::from)
        .map(Business::getId)
        .flatMap(service::getReviewsRx)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(businesses -> updateUi());