Tag: frp

将Observable收集到List中似乎不会立即发出集合

我正在使用RxJava来实质上收集单独发出的Observable的列表，并将它们组合成一个Observable列表（基本上与flatMap相反）。 这是我的代码： // myEvent.findMemberships() returns an Observable<List> myEvent.findMemberships() .flatMap(new Func1<List, Observable>() { @Override public Observable call(List memberships) { List users = new ArrayList(); for (Membership membership : memberships) { users.add(membership.getUser()); } return Observable.from(users); } }) .toList() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer<List>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { Timber.e(e, “Error […]