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

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

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

Observable.sequenceEqual介绍

[英]Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the same by comparing the items emitted by each Observable pairwise.

Scheduler: sequenceEqual does not operate by default on a particular Scheduler.
[中]返回一个Observable,它发出一个布尔值,通过比较每个Observable成对发出的项来指示两个Observable序列是否相同。
Scheduler:sequenceEqual默认情况下不会在特定的计划程序上运行。

代码示例

代码示例来源:origin: com.netflix.rxjava/rxjava-core

  1. return sequenceEqual(first, second, new Func2<T, T, Boolean>() {
  2. @Override
  3. public final Boolean call(T first, T second) {

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

  1. @Override
  2. public void run() {
  3. Observable.sequenceEqual(Observable.just(1, 2, 3),
  4. Observable.range(1, 3),
  5. new Func2<Integer, Integer, Boolean>() {
  6. @Override
  7. public Boolean call(Integer integer1, Integer integer2) {
  8. return integer1 == integer2;
  9. }
  10. }).subscribe(new Action1<Boolean>() {
  11. @Override
  12. public void call(Boolean aBoolean) {
  13. log(aBoolean);
  14. }
  15. });
  16. }
  17. });

代码示例来源:origin: hawkular/hawkular-metrics

  1. .collect(HashSet<UUID>::new, HashSet::add);
  2. Observable<? extends Set<UUID>> finished = findFinishedJobs(time);
  3. return Observable.sequenceEqual(scheduled, finished).flatMap(allFinished -> {
  4. if (allFinished) {
  5. logger.debugf("All jobs for time slice [%s] have finished", time);

相关文章

Observable类方法