android - 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

因此第二次调用取决于第一次调用的数据。

在retrofit2中，我将以下设置设置为服务:

   @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);

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

我不知道如何在 RXjava 中启动它。我知道我需要一张平面图，但我对要使用的 POJO 以及如何使其工作有点困惑。这是在 Android 设备上。

如果需要的话，我的企业 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());