zip rxjava運營商不能解決方法訂閱

Question

我想通過網絡發送多個請求，這tutorial 幫助，但我卡在後半部分。 似乎我預計將從onSubscribe，onNext，...返回一個值（OrderValues）... 因爲apply函數返回一個值。但是，onNext默認返回void。 任何幫助嗎？這是我的一段代碼

Observable<Restaurant> orderRestaurant= IdentityClient.getAPIService() 
     .getRestaurantById(restaurantId) 
     .subscribeOn(Schedulers.newThread()) 
     .observeOn(AndroidSchedulers.mainThread()); 

    Observable<Menu> orderMenu= IdentityClient.getAPIService() 
     .getMenuById(menuId) 
     .subscribeOn(Schedulers.newThread()) 
     .observeOn(AndroidSchedulers.mainThread()); 

    Observable<User> orderUser= IdentityClient.getAPIService() 
     .getUserById(userId) 
     .subscribeOn(Schedulers.newThread()) 
     .observeOn(AndroidSchedulers.mainThread()); 

    Observable<OrderValues> combineValues=Observable.zip(orderRestaurant, 
    orderMenu, orderUser, 
     new Function3<Restaurant, Menu, User, OrderValues>() { 
    @Override 
    public OrderValues apply(Restaurant restaurant, Menu menu, User user) 
    throws Exception { 
     return new OrderValues(restaurant,menu,user); 
    } 
I get an error here "cannot resolve method 'subscribe anonymous 
org.reactivestreams.Subscriber(....OrderValues) 
    }).subscribe(new Subscriber<OrderValues>() { 
    @Override 
    public void onSubscribe(Subscription s) { 

    } 

    @Override 
    public void onNext(OrderValues orderValues) { 

    } 

    @Override 
    public void onError(Throwable t) { 

    } 

    @Override 
    public void onComplete() { 

    } 
    }); 

Answer 1

我假設你正在使用RxJava 2.

使用Observer而不是Subscriber。也不要將結果分配給新的Observable（你稱之爲combineValues）。

private void myMethod() { 
    Observable.zip(orderRestaurant, orderMenu, orderUser, new Function3<Restaurant, Menu, User, OrderValues>() { 
       @Override 
       public OrderValues apply(@NonNull Restaurant restaurant, @NonNull Menu menu, @NonNull User user) throws Exception { 
        return new OrderValues(restaurant, menu, user); 
       } 
      }).subscribe(new Observer<OrderValues>() { 
       @Override 
       public void onSubscribe(Disposable d) { 

       } 

       @Override 
       public void onNext(OrderValues orderValues) { 

       } 

       @Override 
       public void onError(Throwable e) { 

       } 

       @Override 
       public void onComplete() { 

       } 
      }); 
     } 
    }