可观察到的在科特林列出

Question

 @GET("/")
fun getInfo(@Query("pew") pew1: Double, @Query("pew2") pew2: Double): Observable<PewResponse>

private var mPewList: MutableList<PewList> = arrayListOf()

override fun getResultFromNetwork(): Observable<PewResponse> {
    val pewObservable = pewService.getInfo("pew1","pew2")
    return pewObservable.concatMap {
      //How do I fill my list ??

    }


}

我遵循这个示例https://github.com/joanby/android-mvp/blob/master/moviesfeed/app/src/main/java/com/juangabriel/moviesfeed/movies/moviesrepository.java

现在我想做这样的事情：

@Override
public Observable<Result> getResultFromNetwork() {

    Observable<TopMoviesRated> topMoviesRatedObservable = moviesApiService.getTopMoviesRated(1)
            /*.concatWith(moviesApiService.getTopMoviesRated(2))
            .concatWith(moviesApiService.getTopMoviesRated(3))*/;

    return topMoviesRatedObservable
            .concatMap(new Function<TopMoviesRated, Observable<Result>>() {
                @Override
                public Observable<Result> apply(TopMoviesRated topMoviesRated) {
                    return Observable.fromIterable(topMoviesRated.getResults());
                }
            }).doOnNext(new Consumer<Result>() {
                @Override
                public void accept(Result result) {
                    results.add(result);
                }
            });

}

因此，正如我所看到的，他填充了结果列表，然后在演示者上执行以下操作：https://github.com/joanby/android-mvp/blob/master/moviesfeed/app/src/main/java/com/juangabriel/moviesfeed/movies/moviespresenter.java

Answer 1

如果来自服务器的数据是单块的，则应该使用single，因为它只返回一次值。当数据以块的形式到达时，可观察的将执行。

有关更多详细信息，您可以查看以下答案:https://stackoverflow.com/a/42759432/9060113

编辑：

@GET("/")
fun getInfo(@Query("pew") pew1: Double, @Query("pew2") pew2: Double): Single<PewResponse>


override fun getResultFromNetwork() {
  pewService
     .getInfo("pew1","pew2")
     .subscribeOn(Schedulers.io()) // for background processing
     .observeOn(AndroidSchedulers.mainThread()) // get result in Main Thread (it require rxAndroid lib)
     .subscribe(
       { pewResponse -> // parse response and fill list },
       { // handle error }
     )
}