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

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

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

Observable.forEach介绍

[英]Subscribes to the Observable and receives notifications for each element.

Alias to #subscribe(Action1) Scheduler: forEach does not operate by default on a particular Scheduler.
[中]订阅Observable并接收每个元素的通知。
#订阅（Action1）调度程序别名：forEach默认情况下不会在特定调度程序上运行。

代码示例

代码示例来源：origin: apache/usergrid

  1. private List<UUID> getAllVersions( final EntityCollectionManager ecm,
  2.                   final Id entityId ) {
  3.   final List<UUID> versions = new ArrayList<>();
  4.   ecm.getVersionsFromMaxToMin(entityId, UUIDUtils.newTimeUUID())
  5.     .forEach( mvccLogEntry -> {
  6.       versions.add(mvccLogEntry.getVersion());
  7.     });
  8.   return versions;
  9. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. /**
  2.  * 设置轮播banners
  3.  */
  4. private void convertBanner() {
  5.   Observable.from(recommendBanners)
  6.       .compose(bindToLifecycle())
  7.       .forEach(dataBean -> banners.add(new BannerEntity(dataBean.getValue(),
  8.           dataBean.getTitle(), dataBean.getImage())));
  9. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. private void setBanner() {
  2.   Observable.from(banners)
  3.       .compose(bindToLifecycle())
  4.       .forEach(topBean -> bannerEntities.add(new BannerEntity(
  5.           topBean.getUri(), topBean.getTitle(), topBean.getImage())));
  6. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. private void setBanner() {
  2.   Observable.from(banners)
  3.       .compose(bindToLifecycle())
  4.       .forEach(topBean -> bannerEntities.add(new BannerEntity(topBean.getUri(),
  5.           topBean.getTitle(), topBean.getImage())));
  6. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. public void setLiveInfo(LiveAppIndexInfo liveAppIndexInfo) {
  2.   this.mLiveAppIndexInfo = liveAppIndexInfo;
  3.   entranceSize = 4;
  4.   liveSizes.clear();
  5.   bannerEntitys.clear();
  6.   int tempSize = 0;
  7.   int partitionSize = mLiveAppIndexInfo.getData().getPartitions().size();
  8.   List<LiveAppIndexInfo.DataBean.BannerBean> banner = mLiveAppIndexInfo.getData().getBanner();
  9.   Observable.from(banner)
  10.       .forEach(bannerBean -> bannerEntitys.add(new BannerEntity(
  11.           bannerBean.getLink(), bannerBean.getTitle(), bannerBean.getImg())));
  12.   for (int i = 0; i < partitionSize; i++) {
  13.     liveSizes.add(tempSize);
  14.     tempSize += mLiveAppIndexInfo.getData().getPartitions().get(i).getLives().size();
  15.   }
  16. }

代码示例来源：origin: apache/usergrid

  1. private List<UUID> getVersionsOlderThanMarked(final EntityCollectionManager ecm, final Id entityId,
  2.                        final UUID markedVersion ){
  3.   final List<UUID> versions = new ArrayList<>();
  4.   // only take last 100 versions to avoid eating memory. a tool can be built for massive cleanups for old usergrid
  5.   // clusters that do not have this in-line cleanup
  6.   ecm.getVersionsFromMaxToMin( entityId, markedVersion)
  7.     .take(100)
  8.     .forEach( mvccLogEntry -> {
  9.       if ( mvccLogEntry.getVersion().timestamp() < markedVersion.timestamp() ) {
  10.         versions.add(mvccLogEntry.getVersion());
  11.       }
  12.     });
  13.   return versions;
  14. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. public void finishTask() {
  3.   Observable.from(results)
  4.       .compose(bindToLifecycle())
  5.       .forEach(resultBean -> mSectionedRecyclerViewAdapter.addSection(
  6.           new SeasonNewBangumiSection(SeasonNewBangumiActivity.this,
  7.               resultBean.getSeason(), resultBean.getYear(), resultBean.getList())));
  8.   mSectionedRecyclerViewAdapter.notifyDataSetChanged();
  9.   hideProgressBar();
  10. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. public void finishTask() {
  3.   Observable.from(bangumiSchedules)
  4.       .compose(bindToLifecycle())
  5.       .forEach(this::accordingWeekGroup);
  6.   mSectionedAdapter.addSection(new BangumiScheduleSection(BangumiScheduleActivity.this, sundayBangumis, ConstantUtil.SUNDAY_TYPE,
  7.       saturdayBangumis.size() > 0 ? WeekDayUtil.formatDate(sundayBangumis.get(0).getPub_date()) : ""));
  8.   mSectionedAdapter.addSection(new BangumiScheduleSection(BangumiScheduleActivity.this, mondayBangumis, ConstantUtil.MONDAY_TYPE,
  9.       mondayBangumis.size() > 0 ? WeekDayUtil.formatDate(mondayBangumis.get(0).getPub_date()) : ""));
  10.   mSectionedAdapter.addSection(new BangumiScheduleSection(BangumiScheduleActivity.this, tuesdayBangumis, ConstantUtil.TUESDAY_TYPE,
  11.       tuesdayBangumis.size() > 0 ? WeekDayUtil.formatDate(tuesdayBangumis.get(0).getPub_date()) : ""));
  12.   mSectionedAdapter.addSection(new BangumiScheduleSection(BangumiScheduleActivity.this, wednesdayBangumis, ConstantUtil.WEDNESDAY_TYPE,
  13.       wednesdayBangumis.size() > 0 ? WeekDayUtil.formatDate(wednesdayBangumis.get(0).getPub_date()) : ""));
  14.   mSectionedAdapter.addSection(new BangumiScheduleSection(BangumiScheduleActivity.this, thursdayBangumis, ConstantUtil.THURSDAY_TYPE,
  15.       thursdayBangumis.size() > 0 ? WeekDayUtil.formatDate(thursdayBangumis.get(0).getPub_date()) : ""));
  16.   mSectionedAdapter.addSection(new BangumiScheduleSection(BangumiScheduleActivity.this, fridayBangumis, ConstantUtil.FRIDAY_TYEP,
  17.       fridayBangumis.size() > 0 ? WeekDayUtil.formatDate(fridayBangumis.get(0).getPub_date()) : ""));
  18.   mSectionedAdapter.addSection(new BangumiScheduleSection(BangumiScheduleActivity.this, saturdayBangumis, ConstantUtil.SATURDAY_TYPE,
  19.       saturdayBangumis.size() > 0 ? WeekDayUtil.formatDate(saturdayBangumis.get(0).getPub_date()) : ""));
  20.   mSectionedAdapter.notifyDataSetChanged();
  21.   hideProgressBar();
  22. }

代码示例来源：origin: Netflix/conductor

  1. @Test
  2. public void test() {
  3.   List<Message> messages = new LinkedList<>();
  4.   Observable.range(0, 10).forEach((Integer x) -> messages.add(new Message("" + x, "payload: " + x, null)));
  5.   assertEquals(10, messages.size());
  6.   SQSObservableQueue queue = mock(SQSObservableQueue.class);
  7.   when(queue.getOrCreateQueue()).thenReturn("junit_queue_url");
  8.   Answer<?> answer = (Answer<List<Message>>) invocation -> Collections.emptyList();
  9.   when(queue.receiveMessages()).thenReturn(messages).thenAnswer(answer);
  10.   when(queue.getOnSubscribe()).thenCallRealMethod();
  11.   when(queue.observe()).thenCallRealMethod();
  12.   List<Message> found = new LinkedList<>();
  13.   Observable<Message> observable = queue.observe();
  14.   assertNotNull(observable);
  15.   observable.subscribe(found::add);
  16.   Uninterruptibles.sleepUninterruptibly(1000, TimeUnit.MILLISECONDS);
  17.   assertEquals(messages.size(), found.size());
  18.   assertEquals(messages, found);
  19. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. protected void finishTask() {
  3.   mSwipeRefreshLayout.setRefreshing(false);
  4.   mIsRefreshing = false;
  5.   hideEmptyView();
  6.   Observable.from(banners)
  7.       .compose(bindToLifecycle())
  8.       .forEach(bannersBean -> bannerList.add(new BannerEntity(
  9.           bannersBean.getLink(), bannersBean.getTitle(), bannersBean.getImg())));
  10.   mSectionedRecyclerViewAdapter.addSection(new HomeBangumiBannerSection(bannerList));
  11.   mSectionedRecyclerViewAdapter.addSection(new HomeBangumiItemSection(getActivity()));
  12.   mSectionedRecyclerViewAdapter.addSection(new HomeBangumiNewSerialSection(getActivity(), newBangumiSerials));
  13.   if (!bangumibobys.isEmpty()) {
  14.     mSectionedRecyclerViewAdapter.addSection(new HomeBangumiBobySection(getActivity(), bangumibobys));
  15.   }
  16.   mSectionedRecyclerViewAdapter.addSection(new HomeBangumiSeasonNewSection(getActivity(), season, seasonNewBangumis));
  17.   mSectionedRecyclerViewAdapter.addSection(new HomeBangumiRecommendSection(getActivity(), bangumiRecommends));
  18.   mSectionedRecyclerViewAdapter.notifyDataSetChanged();
  19. }

代码示例来源：origin: jhusain/learnrxjava

  1. public static void main(String... args) {
  2.     Observable.range(0, 10).reduce(new ArrayList<>(), (list, i) -> {
  3.       list.add(i);
  4.       return list;
  5.     }).forEach(System.out::println);
  7.     System.out.println("... vs ...");
  9.     Observable.range(0, 10).scan(new ArrayList<>(), (list, i) -> {
  10.       list.add(i);
  11.       return list;
  12.     }).forEach(System.out::println);
  13.   }
  14. }

代码示例来源：origin: jhusain/learnrxjava

  1. .flatMap(g -> {
  2.   return g.toList();
  3. }).forEach(System.out::println);
  4. .flatMap(g -> {
  5.   return g.take(10).toList();
  6. }).forEach(System.out::println);
  7. .flatMap(g -> {
  8.   return g.filter(i -> i <= 20).toList();
  9. }).forEach(System.out::println);
  10. .flatMap(g -> {
  11.   return g.take(20).toList();
  12. }).take(2).forEach(System.out::println);
  13. .flatMap(g -> {
  14.   return g.takeWhile(i -> i < 30).toList();
  15. }).filter(l -> !l.isEmpty()).forEach(System.out::println);
  16. .flatMap(g -> {
  17.   return g.take(3).reduce((s, s2) -> s + s2);
  18. }).forEach(System.out::println);

代码示例来源：origin: io.macgyver/macgyver-core

  1. protected Map<String, JsonNode> loadScheduledScriptTasks() {
  2.   Map<String, JsonNode> m = Maps.newConcurrentMap();
  3.   String cypher = "match (s:ScheduledTask) where length(s.script)>0 return s";
  4.   neo4j.execCypher(cypher).forEach(it -> {
  5.     String name = it.path(SCHEDULED_BY_SCRIPT).asText();
  6.     if (!Strings.isNullOrEmpty(name)) {
  7.       m.put(name, it);
  8.     }
  9.   });
  10.   return m;
  11. }

代码示例来源：origin: io.macgyver/macgyver-core

  1. @PreAuthorize("hasAnyRole('ROLE_MACGYVER_USER', 'ROLE_MACGYVER_ADMIN')")
  2. @RequestMapping(value="/api/core/tasks/active",method=RequestMethod.GET,produces=MediaType.APPLICATION_JSON_VALUE)
  3. @ResponseBody
  4. public JsonNode apiActiveTasks() {
  6.   ObjectNode result = mapper.createObjectNode();
  7.   ArrayNode arr = mapper.createArrayNode();
  8.   neo4j.execCypher("match (t:TaskState) where t.state='STARTED' return t order by t.startTs").forEach(it-> {
  9.     arr.add(it);
  10.   });
  11.   result.set("results", arr);
  12.   
  13.   return result;
  14. }

代码示例来源：origin: HotBitmapGG/LeisureRead

  1. private void finishTask() {
  2.  mSwipeRefreshLayout.setRefreshing(false);
  3.  Observable.from(top_stories)
  4.    .forEach(topDailys -> banners.add(new BannerEntity(topDailys.getId(),
  5.      topDailys.getTitle(), topDailys.getImage())));
  6.  mBannerView.delayTime(5).build(banners);
  7.  mRecyclerView.setAdapter(mHeaderViewRecyclerAdapter);
  8.  mAdapter.notifyDataSetChanged();
  9. }

代码示例来源：origin: au.gov.amsa.risky/ais

  1. public static void main(String[] args) {
  2.     Streams.nmeaFromGzip(new File("/media/an/nmea/2015/NMEA_ITU_20150521.gz"))
  3.         .compose(o -> Streams.extract(o)).takeLast(10000).forEach(System.out::println);
  5.   }
  6. }

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

  1. @Test
  2. public void sample_345() throws Exception {
  3.   Observable.combineLatest(
  4.       interval(17, MILLISECONDS).map(x -> "S" + x),
  5.       interval(10, MILLISECONDS).map(x -> "F" + x),
  6.       (s, f) -> f + ":" + s
  7.   ).forEach(System.out::println);
  8.   Sleeper.sleep(Duration.ofSeconds(2));
  9. }

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

  1. @Test
  2. public void sample_618() throws Exception {
  3.   //[A, B, C, D, E...]
  4.   Observable<Character> alphabet =
  5.       Observable
  6.           .range(0, 'Z' - 'A' + 1)
  7.           .map(c -> (char) ('A' + c));
  8.   //[A, C, E, G, I...]
  9.   alphabet
  10.       .compose(odd())
  11.       .forEach(System.out::println);
  12. }

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

  1. @Test
  2. public void sample_355() throws Exception {
  3.   Observable<String> fast = interval(10, MILLISECONDS)
  4.       .map(x -> "F" + x)
  5.       .delay(100, MILLISECONDS)
  6.       .startWith("FX");
  7.   Observable<String> slow = interval(17, MILLISECONDS).map(x -> "S" + x);
  8.   slow
  9.       .withLatestFrom(fast, (s, f) -> s + ":" + f)
  10.       .forEach(System.out::println);
  11. }

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

  1. @Test
  2. public void sample_332() throws Exception {
  3.   Observable<Long> red = interval(10, TimeUnit.MILLISECONDS);
  4.   Observable<Long> green = interval(10, TimeUnit.MILLISECONDS);
  5.   Observable.zip(
  6.       red.timestamp(),
  7.       green.timestamp(),
  8.       (r, g) -> r.getTimestampMillis() - g.getTimestampMillis()
  9.   ).forEach(System.out::println);
  10. }

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

Observable

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Observable类方法

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