本文整理了Java中rx.Single.zip()
方法的一些代码示例,展示了Single.zip()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Single.zip()
方法的具体详情如下:
包路径:rx.Single
类名称: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),
内容来源于网络,如有侵权,请联系作者删除!