lce-combined-stream.java

class UserContent {
 // requires both the user and list of published content
}

Observable<Lce<User>> getUserEventStream(String userId);
Observable<Lce<List<Content>> getContentEventStream(String userId);

Observable<Lce<UserContent>> getProfileEventStream(String id) {
  return Observable.combineLatest(
    getUserEventStream(id),
    getContentEventStream(id),
    { user, content ->
      if (user.isLoading || content.isLoading) {
        return Lce.loading()
      } else if (user.hasError()) {
        return Lce.error(user.getError()
      } else if (content.hasError()) {
        return Lce.error(content)
      } else {
        return Lce.data(createUserContent(
            user.getData(), content.getData())
      }
    })
}