rx.Single.zip()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(222)

本文整理了Java中rx.Single.zip()方法的一些代码示例,展示了Single.zip()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Single.zip()方法的具体详情如下:
包路径:rx.Single
类名称:Single
方法名:zip

Single.zip介绍

暂无

代码示例

代码示例来源:origin: spencergibb/myfeed

Observable<UserFeedItem> initUser(String username, Single<String> userid) {
  int numItems = getNumItems(minItems, maxItems);
  return Observable.range(0, numItems)
      .map(i -> numItems - i)
      .flatMap(i -> {
        Single<String> text = Single.just(randomText.getText(getNumItems(minWords, maxWords)));
        LocalDateTime dateTime = LocalDateTime.now().minusDays(i);
        Single<Date> created = Single.just(Date.from(dateTime.toInstant(ZoneOffset.UTC)));
        Single<String> feedUsername = getRandomUsername(username);
        Single<FeedItem> feedItem = Single.zip(userid, feedUsername, text, created, FeedItem::new);
        return Single.zip(Single.just(username), feedItem, UserFeedItem::new).toObservable();
      })
      .map(userFeedItem -> {
        FeedItem saved = repo.save(userFeedItem.feedItem);
        userFeedItem.feedItem = saved;
        return userFeedItem;
      });
}

代码示例来源:origin: plusCubed/anticipate

Single.zip(DbUtil.getPerAppListApps(this), DbUtil.getInstalledApps(this), new Func2<List<AppInfo>, List<AppInfo>, List<AppInfo>>() {
  @Override
  public List<AppInfo> call(List<AppInfo> perAppList, List<AppInfo> installedApps) {

代码示例来源:origin: nurkiewicz/rxjava-book-examples

@Test
public void sample_98() throws Exception {
  Single<Document> doc = Single.zip(
      content(123),
      likes(123),
      updateReadCount(),
      (con, lks, vod) -> buildHtml(con, lks)
  );
}

代码示例来源:origin: Petikoch/Java_MVVM_with_Swing_and_RxJava_Examples

.subscribe(actionEvent -> vm2v_result2.onNext("Aborted"));
final Single<FinishedIndicator> bothFinished = Single.zip(
    createAccountResult,
    sendEmailResult,

代码示例来源:origin: Petikoch/Java_MVVM_with_Swing_and_RxJava_Examples

.subscribe(actionEvent -> vm2v_result2.onNext("Aborted"));
final Single<FinishedIndicator> bothFinished = Single.zip(
    createAccountResult.onErrorReturn(throwable -> FinishedIndicator.INSTANCE),
    sendEmailResult.onErrorReturn(throwable -> FinishedIndicator.INSTANCE),

相关文章