rx.Observable.flatMapIterable()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(283)

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

Observable.flatMapIterable介绍

[英]Returns an Observable that merges each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector.

Scheduler: flatMapIterable does not operate by default on a particular Scheduler.
[中]

代码示例

代码示例来源：origin: io.github.moacchain/core

  1. public Observable<Transaction> catchUpToLatestAndSubscribeToNewTransactionsObservable(
  2.     DefaultBlockParameter startBlock, long pollingInterval) {
  3.   return catchUpToLatestAndSubscribeToNewBlocksObservable(
  4.       startBlock, true, pollingInterval)
  5.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  6. }

代码示例来源：origin: org.nervos/core

  1. public Observable<Transaction> catchUpToLatestAndSubscribeToNewTransactionsObservable(
  2.     DefaultBlockParameter startBlock, long pollingInterval) {
  3.   return catchUpToLatestAndSubscribeToNewBlocksObservable(
  4.       startBlock, true, pollingInterval)
  5.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  6. }

代码示例来源：origin: io.github.moacchain/core

  1. public Observable<Transaction> replayTransactionsObservable(
  2.     DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
  3.   return replayBlocksObservable(startBlock, endBlock, true)
  4.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  5. }

代码示例来源：origin: FISCO-BCOS/web3sdk

  1. public Observable<Transaction> replayTransactionsObservable(
  2.     DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
  3.   return replayBlocksObservable(startBlock, endBlock, true)
  4.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  5. }

代码示例来源：origin: FISCO-BCOS/web3sdk

  1. public Observable<Transaction> catchUpToLatestAndSubscribeToNewTransactionsObservable(
  2.     DefaultBlockParameter startBlock, long pollingInterval) {
  3.   return catchUpToLatestAndSubscribeToNewBlocksObservable(
  4.       startBlock, true, pollingInterval)
  5.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  6. }

代码示例来源：origin: org.nervos/core

  1. public Observable<Transaction> replayTransactionsObservable(
  2.     DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
  3.   return replayBlocksObservable(startBlock, endBlock, true)
  4.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  5. }

代码示例来源：origin: org.nervos/core

  1. public Observable<Transaction> transactionObservable(long pollingInterval) {
  2.   return blockObservable(true, pollingInterval)
  3.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  4. }

代码示例来源：origin: Aptoide/aptoide-client-v8

  1. public Observable<Download> getCurrentDownload() {
  2.  return getDownloads().flatMapIterable(downloads -> downloads)
  3.    .filter(downloads -> downloads.getOverallDownloadStatus() == Download.PROGRESS);
  4. }

代码示例来源：origin: org.nervos/core

  1. public Observable<Transaction> catchUpToLatestTransactionObservable(
  2.     DefaultBlockParameter startBlock) {
  3.   return catchUpToLatestBlockObservable(
  4.       startBlock, true, Observable.empty())
  5.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  6. }

代码示例来源：origin: neow3j/neow3j

  1. public Observable<Transaction> catchUpToLatestTransactionObservable(
  2.     BlockParameter startBlock) {
  3.   return catchUpToLatestBlockObservable(
  4.       startBlock, true, Observable.empty())
  5.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  6. }

代码示例来源：origin: davidmoten/rxjava-extras

  1. @Override
  2.   public Observable<T> call(Observable<T> o) {
  3.     return o.toSortedList().flatMapIterable(Functions.<List<T>> identity());
  4.   }
  5. };

代码示例来源：origin: io.github.moacchain/core

  1. public Observable<Transaction> catchUpToLatestTransactionObservable(
  2.     DefaultBlockParameter startBlock) {
  3.   return catchUpToLatestBlockObservable(
  4.       startBlock, true, Observable.empty())
  5.       .flatMapIterable(JsonRpc2_0Rx::toTransactions);
  6. }

代码示例来源：origin: com.github.davidmoten/rxjava-extras

  1. @Override
  2.   public Observable<T> call(Observable<T> o) {
  3.     return o.toSortedList().flatMapIterable(Functions.<List<T>> identity());
  4.   }
  5. };

代码示例来源：origin: Aptoide/aptoide-client-v8

  1. @Override public Completable pauseAllDownloads() {
  2.  return downloadsRepository.getDownloadsInProgress()
  3.    .filter(downloads -> !downloads.isEmpty())
  4.    .flatMapIterable(downloads -> downloads)
  5.    .flatMap(download -> getAppDownloader(download.getMd5()).flatMapCompletable(
  6.      appDownloader -> appDownloader.pauseAppDownload())
  7.      .map(appDownloader -> download))
  8.    .toCompletable();
  9. }

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

  1. public Observable<List<FeedItem>> feed(String username) {
  2.   return user.findId(username).toObservable()
  3.       .flatMap(userid -> {
  4.         if (StringUtils.hasText(userid)) {
  5.           return Observable.from(repo.findByUserid(userid));
  6.         } else {
  7.           return Observable.just(singletonFeed("Unknown user: " + username));
  8.         }
  9.       })
  10.       // sort by created desc since redis repo doesn't support order
  11.       .flatMapIterable(feedItems -> feedItems)
  12.       .toSortedList((feedItem1, feedItem2) -> feedItem2.getCreated().compareTo(feedItem1.getCreated()));
  13. }

代码示例来源：origin: com.github.davidmoten/rxjava-extras

  1. @Override
  2.   public Observable<T> call(Observable<T> o) {
  3.     return o.toSortedList(Functions.toFunc2(comparator))
  4.         .flatMapIterable(Functions.<List<T>> identity());
  5.   }
  6. };

代码示例来源：origin: davidmoten/rxjava-extras

  1. @Override
  2.   public Observable<T> call(Observable<T> o) {
  3.     return o.toSortedList(Functions.toFunc2(comparator))
  4.         .flatMapIterable(Functions.<List<T>> identity());
  5.   }
  6. };

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

  1. Observable<PGNotification> pollForNotifications(
  2.     long pollingPeriod,
  3.     AbstractJdbc2Connection pgConn) {
  4.   return Observable
  5.       .interval(0, pollingPeriod, TimeUnit.MILLISECONDS)
  6.       .flatMap(x -> tryGetNotification(pgConn))
  7.       .filter(arr -> arr != null)
  8.       .flatMapIterable(Arrays::asList);
  9. }

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

  1. @Test
  2. public void sample_147() throws Exception {
  3.   Observable<Integer> odd = Observable
  4.       .range(1, 7)
  5.       .buffer(1, 2)
  6.       .flatMapIterable(list -> list);
  7. }

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

  1. Observable<Item> observeNewItems() {
  2.   return Observable
  3.       .interval(1, TimeUnit.SECONDS)
  4.       .flatMapIterable(x -> query())
  5.       .distinct();
  6. }

内容来源于网络，如有侵权，请联系作者删除！

Observable

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Observable类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com