如何使用带有改型的RxJava从多个API获取数据2

Question

我是RxJava的新手。我想从JSON API中获取数据。假设有两个API API 1和API 2.我们从API 1中获取一个JSON对象“mediaId”。现在，我想用“mediaId”从API 2获取JSON。我如何使用RxJava实现这一点，并在Android中进行改进？

public void gettdata(final Listerner listerner){ 

    postitemses= new ArrayList<>(); 
    Retrofit retrofit = new Retrofit.Builder() 
      .baseUrl("https://www.mytrendin.com") 
      .addConverterFactory(GsonConverterFactory.create()) 
      .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) 
      .build(); 

    APiService networkAPI = retrofit.create(APiService.class); 

    Observable<List<Postitems>> observable = networkAPI.getFriendObservable() 
            .subscribeOn(Schedulers.newThread()) 
            .observeOn(AndroidSchedulers.mainThread()); 

    observable.subscribe(new Observer<List<Postitems>>() { 
     @Override 
     public void onCompleted() { 

     } 

     @Override 
     public void onError(Throwable e) { 

      listerner.onFailure("oops... Something went wrong"); 
     } 

     @Override 
     public void onNext(List<Postitems> postitemsList1) { 

      Postitems postitems; 
      for (int i=0;i<postitemsList1.size();i++){ 
       postitems = new Postitems(); 
       int id = postitemsList1.get(i).getId(); 
       String title = postitemsList1.get(i).getTitle().getRendered(); 
       String shortdesc= postitemsList1.get(i).getExcerpt().getRendered(); 
       String mediaid= postitemsList1.get(i).getFeatured_media(); 
       String authorid= postitemsList1.get(i).getAuthor(); 
       String date = postitemsList1.get(i).getDate(); 
       String slug = postitemsList1.get(i).getSlug(); 
       Log.i("Hello-slug",""+slug); 
       String[] mediaurl= mydata(mediaid); 
       Log.i("Hello-mediaurl",""+mediaurl); 
       postitems.setId(id); 
       postitems.setDate(date); 
       postitems.setSlug(""+slug); 
       postitems.setPostExcerpt(shortdesc); 
       postitems.setPostTitle(title); 
       postitemses.add(postitems); 

      } 
      listerner.showpostitems(postitemses); 

     } 
    }); 


} 




public String[] mydata(String mediaid){ 


    final String[] mediaurl = new String[1]; 
    Retrofit retrofit = new Retrofit.Builder() 
      .addConverterFactory(GsonConverterFactory.create()) 
      .baseUrl("https://www.mytrendin.com") 
      .build(); 
    APiService aPiService = retrofit.create(APiService.class); 
    Call<Postitems> call = aPiService.getmediaurl(mediaid); 
    call.enqueue(new Callback<Postitems>() { 
     @Override 
     public void onResponse(Call<Postitems> call, Response<Postitems> response) { 

      Postitems postitemsList1 = response.body(); 
      mediaurl[0] =postitemsList1.getGuid().getRendered(); 
      // mediaurl[0][0] =postitemsList1.get(0).getGuid().getRendered(); 
     } 

     @Override 
     public void onFailure(Call<Postitems> call, Throwable t) { 

     } 
    }); 

    return mediaurl; 

}

出错

https://www.mytrendin.com 3月5日至9日：42：09.227 15315-15315 /？ d/AndroidRuntime：关闭VM

          --------- beginning of crash 

3月5日至9日：42：09.228 15315-15315 /？ E/AndroidRuntime：致命例外：main 进程：com.mytrendin.mytrendin，PID：15315 java.lang.NullPointerException：试图调用虚方法.mytrendin.dashboard.utils.Po stitems $ Guid（ZygoteInit.java:755）

Answer 1

当然你可以使用该合并操作与IO scheduler.By定义一起，合并可以合并他们emissions.here就是一个例子多观测量合并成一个，

Observable<Integer> odds = Observable.just(1, 3, 5).subscribeOn(someScheduler); 
Observable<Integer> evens = Observable.just(2, 4, 6); 

Observable.merge(odds, evens) 
      .subscribe(new Subscriber<Integer>() { 
     @Override 
     public void onNext(Integer item) { 
      System.out.println("Next: " + item); 
     } 

     @Override 
     public void onError(Throwable error) { 
      System.err.println("Error: " + error.getMessage()); 
     } 

     @Override 
     public void onCompleted() { 
      System.out.println("Sequence complete."); 
     } 
    }); 

输出：

下一步：1

下一页：3

下一页：5

下一页：2

下一页：4

下一页：6

序列完整。

像这样的事情在你的情况，

public Observable<Data> getMergedData() { 
    return Observable.merge(
    networkRepository.getData().subscribeOn(Schedulers.io()), 
    networkRepository.getData().subscribeOn(Schedulers.io()) 
); 
} 

好吧，还有另一种方式来解决这个问题，首先要创建一个可观察到的两个API，然后订阅并观察从你的第一API subscription.Next创建的变化一个PublishSubject实例。这很有用，因为一旦观察者已经订阅，就会将所有随后观察到的项目发送给订阅者。例如，从API响应中发布字符串值。

private PublishSubject<String> subject = PublishSubject.create(); 


subject.observeOn(AndroidSchedulers.mainThread()).subscribeOn(Schedulers.io()).filter((s) -> s.size() > 0).subscribe(new Observer<String>() { 
      @Override 
      public void onSubscribe(Disposable d) { 

      } 

      @Override 
      public void onNext(String str) { 


      } 

      @Override 
      public void onError(Throwable e) { 

      } 

      @Override 
      public void onComplete() { 

      } 
     }); 

---

然后触发来自受试者的观察到的呼叫onNext。

subject.onNext("some data from api"); 

优点，非常灵活地改变你的班级范围内的任何地方。

希望这会有所帮助。

为以下片断

call.enqueue(new Callback<Postitems>() { 
     @Override 
     public void onResponse(Call<Postitems> call, Response<Postitems> response) { 

      Postitems postitemsList1 = response.body(); 
      mediaurl[0] =postitemsList1.getGuid().getRendered(); 
      // mediaurl[0][0] =postitemsList1.get(0).getGuid().getRendered(); 
//use the concept of publish subject here, which i detailed in answer, example 
subject.onNext(postitemsList1.getGuid().getRendered()); 
//the string data will be passed to the above observable for the subject instance. 
     } 

     @Override 
     public void onFailure(Call<Postitems> call, Throwable t) { 

     } 
    });