io.reactivex.Flowable.any()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(220)

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

Flowable.any介绍

[英]Returns a Single that emits true if any item emitted by the source Publisher satisfies a specified condition, otherwise false. Note: this always emits false if the source Publisher is empty.

In Rx.Net this is the any operator but we renamed it in RxJava to better match Java naming idioms. Backpressure: The operator honors backpressure from downstream and consumes the source Publisher in an unbounded manner (i.e., no backpressure applied to it). Scheduler: any does not operate by default on a particular Scheduler.
[中]如果源发布服务器发出的任何项满足指定条件，则返回一个值，该值为true，否则为false*注意：*如果源发布服务器为空，则此消息始终发出false。
在Rx。Net这是any操作符，但我们在RxJava中重命名了它，以便更好地匹配Java命名习惯用法。背压：操作员接受来自下游的背压，并以无限制的方式使用源发布服务器（即，不向其施加背压）。调度程序：默认情况下，任何调度程序都不会在特定的调度程序上运行。

代码示例

代码示例来源：origin: ReactiveX/RxJava

  1. @Test(expected = NullPointerException.class)
  2. public void anyPredicateNull() {
  3.   just1.any(null);
  4. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Override
  2.   public Single<Boolean> apply(Flowable<Object> f) throws Exception {
  3.     return f.any(Functions.alwaysTrue());
  4.   }
  5. });

代码示例来源：origin: ReactiveX/RxJava

  1. @Override
  2.   public Publisher<Boolean> apply(Flowable<Object> f) throws Exception {
  3.     return f.any(Functions.alwaysTrue()).toFlowable();
  4.   }
  5. });

代码示例来源：origin: ReactiveX/RxJava

  1. @Override
  2. public Publisher<Boolean> createPublisher(final long elements) {
  3.   return
  4.       Flowable.range(1, 1000).any(new Predicate<Integer>() {
  5.         @Override
  6.         public boolean test(Integer e) throws Exception {
  7.           return e == 500;
  8.         }
  9.       }).toFlowable()
  10.     ;
  11. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testAnyWithOneItem() {
  3.   Flowable<Integer> w = Flowable.just(1);
  4.   Single<Boolean> single = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer v) {
  7.       return true;
  8.     }
  9.   });
  10.   SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  11.   single.subscribe(observer);
  12.   verify(observer, never()).onSuccess(false);
  13.   verify(observer, times(1)).onSuccess(true);
  14.   verify(observer, never()).onError(any(Throwable.class));
  15. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testAnyWithPredicate2() {
  3.   Flowable<Integer> w = Flowable.just(1, 2, 3);
  4.   Single<Boolean> single = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer t1) {
  7.       return t1 < 1;
  8.     }
  9.   });
  10.   SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  11.   single.subscribe(observer);
  12.   verify(observer, times(1)).onSuccess(false);
  13.   verify(observer, never()).onSuccess(true);
  14.   verify(observer, never()).onError(any(Throwable.class));
  15. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testExists1() {
  3.   Flowable<Integer> w = Flowable.just(1, 2, 3);
  4.   Single<Boolean> single = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer t1) {
  7.       return t1 < 2;
  8.     }
  9.   });
  10.   SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  11.   single.subscribe(observer);
  12.   verify(observer, never()).onSuccess(false);
  13.   verify(observer, times(1)).onSuccess(true);
  14.   verify(observer, never()).onError(any(Throwable.class));
  15. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testAnyWithPredicate1() {
  3.   Flowable<Integer> w = Flowable.just(1, 2, 3);
  4.   Single<Boolean> single = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer t1) {
  7.       return t1 < 2;
  8.     }
  9.   });
  10.   SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  11.   single.subscribe(observer);
  12.   verify(observer, never()).onSuccess(false);
  13.   verify(observer, times(1)).onSuccess(true);
  14.   verify(observer, never()).onError(any(Throwable.class));
  15. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testAnyWithTwoItems() {
  3.   Flowable<Integer> w = Flowable.just(1, 2);
  4.   Single<Boolean> single = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer v) {
  7.       return true;
  8.     }
  9.   });
  10.   SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  11.   single.subscribe(observer);
  12.   verify(observer, never()).onSuccess(false);
  13.   verify(observer, times(1)).onSuccess(true);
  14.   verify(observer, never()).onError(any(Throwable.class));
  15. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testAnyWithEmpty() {
  3.   Flowable<Integer> w = Flowable.empty();
  4.   Single<Boolean> single = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer v) {
  7.       return true;
  8.     }
  9.   });
  10.   SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  11.   single.subscribe(observer);
  12.   verify(observer, times(1)).onSuccess(false);
  13.   verify(observer, never()).onSuccess(true);
  14.   verify(observer, never()).onError(any(Throwable.class));
  15. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testExists1Flowable() {
  3.   Flowable<Integer> w = Flowable.just(1, 2, 3);
  4.   Flowable<Boolean> flowable = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer t1) {
  7.       return t1 < 2;
  8.     }
  9.   }).toFlowable();
  10.   Subscriber<Boolean> subscriber = TestHelper.mockSubscriber();
  11.   flowable.subscribe(subscriber);
  12.   verify(subscriber, never()).onNext(false);
  13.   verify(subscriber, times(1)).onNext(true);
  14.   verify(subscriber, never()).onError(any(Throwable.class));
  15.   verify(subscriber, times(1)).onComplete();
  16. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testAnyWithEmptyFlowable() {
  3.   Flowable<Integer> w = Flowable.empty();
  4.   Flowable<Boolean> flowable = w.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer v) {
  7.       return true;
  8.     }
  9.   }).toFlowable();
  10.   Subscriber<Boolean> subscriber = TestHelper.mockSubscriber();
  11.   flowable.subscribe(subscriber);
  12.   verify(subscriber, times(1)).onNext(false);
  13.   verify(subscriber, never()).onNext(true);
  14.   verify(subscriber, never()).onError(any(Throwable.class));
  15.   verify(subscriber, times(1)).onComplete();
  16. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void dispose() {
  3.   TestHelper.checkDisposed(Flowable.just(1).any(Functions.alwaysTrue()).toFlowable());
  4.   TestHelper.checkDisposed(Flowable.just(1).any(Functions.alwaysTrue()));
  5. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testWithFollowingFirst() {
  3.   Flowable<Integer> f = Flowable.fromArray(1, 3, 5, 6);
  4.   Single<Boolean> anyEven = f.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer i) {
  7.       return i % 2 == 0;
  8.     }
  9.   });
  10.   assertTrue(anyEven.blockingGet());
  11. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testWithFollowingFirstFlowable() {
  3.   Flowable<Integer> f = Flowable.fromArray(1, 3, 5, 6);
  4.   Flowable<Boolean> anyEven = f.any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer i) {
  7.       return i % 2 == 0;
  8.     }
  9.   }).toFlowable();
  10.   assertTrue(anyEven.blockingFirst());
  11. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testBackpressureIfOneRequestedOneShouldBeDelivered() {
  3.   TestObserver<Boolean> to = new TestObserver<Boolean>();
  4.   Flowable.just(1).any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer v) {
  7.       return true;
  8.     }
  9.   }).subscribe(to);
  10.   to.assertTerminated();
  11.   to.assertNoErrors();
  12.   to.assertComplete();
  13.   to.assertValue(true);
  14. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. @Ignore("Single doesn't do backpressure")
  3. public void testBackpressureIfNoneRequestedNoneShouldBeDelivered() {
  4.   TestObserver<Boolean> to = new TestObserver<Boolean>();
  5.   Flowable.just(1).any(new Predicate<Integer>() {
  6.     @Override
  7.     public boolean test(Integer t) {
  8.       return true;
  9.     }
  10.   })
  11.   .subscribe(to);
  12.   to.assertNoValues();
  13.   to.assertNoErrors();
  14.   to.assertNotComplete();
  15. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2.   public void testPredicateThrowsExceptionAndValueInCauseMessageFlowable() {
  3.     TestSubscriber<Boolean> ts = new TestSubscriber<Boolean>();
  4.     final IllegalArgumentException ex = new IllegalArgumentException();
  6.     Flowable.just("Boo!").any(new Predicate<String>() {
  7.       @Override
  8.       public boolean test(String v) {
  9.         throw ex;
  10.       }
  11.     }).toFlowable().subscribe(ts);
  13.     ts.assertTerminated();
  14.     ts.assertNoValues();
  15.     ts.assertNotComplete();
  16.     ts.assertError(ex);
  17.     // FIXME value as last cause?
  18. //        assertTrue(ex.getCause().getMessage().contains("Boo!"));
  19.   }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testBackpressureIfNoneRequestedNoneShouldBeDeliveredFlowable() {
  3.   TestSubscriber<Boolean> ts = new TestSubscriber<Boolean>(0L);
  4.   Flowable.just(1).any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer t) {
  7.       return true;
  8.     }
  9.   }).toFlowable()
  10.   .subscribe(ts);
  11.   ts.assertNoValues();
  12.   ts.assertNoErrors();
  13.   ts.assertNotComplete();
  14. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void testBackpressureIfOneRequestedOneShouldBeDeliveredFlowable() {
  3.   TestSubscriber<Boolean> ts = new TestSubscriber<Boolean>(1L);
  4.   Flowable.just(1).any(new Predicate<Integer>() {
  5.     @Override
  6.     public boolean test(Integer v) {
  7.       return true;
  8.     }
  9.   }).toFlowable().subscribe(ts);
  10.   ts.assertTerminated();
  11.   ts.assertNoErrors();
  12.   ts.assertComplete();
  13.   ts.assertValue(true);
  14. }

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

Flowable

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Flowable类方法

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