如何使用Observables，RxJava和Android来访问Webapi？

-1

我想使用RxJava来链接请求列表，但我无法弄清楚如何正确地做到这一点。我有一个列表（LIST_A），我想迭代并将其数据发送到第一个服务（SERVICE_A）。只要我得到响应，我必须发送一个新列表（LIST_B）到第二个Web服务（SERVICE_B）。流量： - > LOOP（LIST_A） SEND ITEM_A - >> 后发送此ITEM_A（它需要启动第二环（LIST_B）和发送的所有项目） - END LOOP如何使用Observables，RxJava和Android来访问Webapi？

那是什么到目前为止，我已经做了：

private static <T> Observable<T> makeObservable(final Callable<T> func) { 
    return Observable.create(
      new Observable.OnSubscribe<T>() { 
       @Override 
       public void call(Subscriber<? super T> subscriber) { 
        try { 
         subscriber.onNext(func.call()); 
        } catch(Exception ex) { 
         Log.e("OP_DAO", "Error reading from the database", ex); 
        } 
       } 
      }); 
} 

public Observable<List<VisitInfo>> getVisitObservable() { 
    return makeObservable(this.getVisit()) 
      .subscribeOn(Schedulers.computation()) ; 
} 

public Callable<List<VisitInfo>> getVisit() { 
    return new Callable<List<PesquisaInfo>>() { 
     @Override 
     public List<VisitInfo> call() throws Exception { 
      List<VisitInfo> list = new ArrayList<VisitInfo>(); 

      // 1. build the query 
      String query = "SELECT * FROM " 
        + VISIT ; 
      // 2. get reference to writable DB 

      try { 
       Cursor cursor = getMyWritableDatabase().rawQuery(query, null); 
       // 3. go over each row, build book and add it to list 
       if (cursor.moveToFirst()) { 
        do { 
         VisitInfo v = new VisitInfo(); 
         ... 
         list.add(v); 
        } while (cursor.moveToNext()); 
        closeCursor(cursor); 
       } 
       return list; 
      } finally { 
       closeDatabase(); 
      } 
     } 
    }; 

} 

Client client = new ServiceGenerator().createService(Client.class); 
Call<List<WS01>> wsServiceCall = client.GetData(user); 
Call<List<WS02>> wsService2Call = client.GetData2(dependent of first call);

任何人都可以帮我请，我花了几天试图了解如何使用RxJava和改造，但它正在比我预料的要难。

来源

2016-06-07 Marcelo Macedo

所以，目前还不清楚你想做什么;你需要以下哪一项？（for list_a中的A）{clientA.sendA}; for（B in list_B）{clientB.sendB};'或'for（A in list_a）{clientA.sendA; for（B in list_B）{clientB.sendB}; };'？ –

第二个选项，但sendB只有在sendA收到答案后才需要执行。谢谢你试图帮助Tassos Bassoukos，我真的很感激！ –

那么，你需要更好地描述你的问题;使用一些伪代码或序列图。

一种方式做你想要的东西大致如下：

import static Observable.*; 

public List<VisitInfo> getVisit() { /* just do the db things here */ } 

return defer(() -> from(getVisit())) 
     .flatMap(visit -> 
      fromCallable(client.getData(visit)) 
      .flatMapIterable(otherList -> otherList) 
      .flatMap(other -> fromCallable(client.getData2(visit, other))));

如果您使用的改造，那么你甚至都不需要fromCallable电话，才使接口方法返回观测量。

来源

2016-06-08 16:13:36

如何使用Observables，RxJava和Android来访问Webapi？

回答

相关问题