ShellyDong

Observable.merge(Observable.from(getRawSelfPosts()), Observable.from(getRawFriendPosts()), Observable.from(getRawNearbyPosts(activity)))
  .distinct((post) -> post.getObjectId())
  .subscribeOn(Schedulers.io());

getRawPostsObs(activity).map((post) -> postToCardModel(post));

new RxList(getRawPostsObs(activity));

getPostsObs(activity).toList().toBlocking().single();