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

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

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

Flowable.to介绍

[英]Calls the specified converter function during assembly time and returns its resulting value.

This allows fluent conversion to any other type. Backpressure: The backpressure behavior depends on what happens in the converter function. Scheduler: to does not operate by default on a particular Scheduler.
[中]在汇编期间调用指定的转换器函数并返回其结果值。
这允许流畅地转换为任何其他类型。背压：背压行为取决于转换器功能中发生的情况。调度程序：默认情况下，不在特定调度程序上运行。

代码示例

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

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

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

  1. .to(new Function<Flowable<Integer>, ConcurrentLinkedQueue<Integer>>() {
  2.   @Override
  3.   public ConcurrentLinkedQueue<Integer> apply(Flowable<Integer> onSubscribe) {

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

  1. @Test
  2. public void testExtend() {
  3.   final TestSubscriber<Object> subscriber = new TestSubscriber<Object>();
  4.   final Object value = new Object();
  5.   Object returned = Flowable.just(value).to(new Function<Flowable<Object>, Object>() {
  6.     @Override
  7.     public Object apply(Flowable<Object> onSubscribe) {
  8.         onSubscribe.subscribe(subscriber);
  9.         subscriber.assertNoErrors();
  10.         subscriber.assertComplete();
  11.         subscriber.assertValue(value);
  12.         return subscriber.values().get(0);
  13.       }
  14.   });
  15.   assertSame(returned, value);
  16. }

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

  1. @Test
  2. public void syncIterable() {
  3.   Flowable.fromIterable(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10))
  4.   .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  5.   .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.SYNC))
  6.   .assertValues(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
  7.   .assertNoErrors()
  8.   .assertComplete();
  9. }

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

  1. @Test
  2.   public void syncIterableHidden() {
  3.     Flowable.fromIterable(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10))
  4.     .hide()
  5.     .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  6.     .assertOf(SubscriberFusion.<Integer>assertNotFuseable())
  7.     .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.NONE))
  8.     .assertValues(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
  9.     .assertNoErrors()
  10.     .assertComplete();
  11.   }
  12. }

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

  1. @Test
  2. public void syncArray() {
  3.   Flowable.fromArray(new Integer[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 })
  4.   .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  5.   .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.SYNC))
  6.   .assertValues(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
  7.   .assertNoErrors()
  8.   .assertComplete();
  9. }

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

  1. @Test
  2. public void syncRange() {
  3.   Flowable.range(1, 10)
  4.   .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  5.   .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.SYNC))
  6.   .assertValues(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
  7.   .assertNoErrors()
  8.   .assertComplete();
  9. }

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

  1. @Test
  2. public void directComparerFused() {
  3.   Flowable.fromArray(1, 2, 2, 3, 2, 4, 1, 1, 2)
  4.   .distinctUntilChanged(new BiPredicate<Integer, Integer>() {
  5.     @Override
  6.     public boolean test(Integer a, Integer b) {
  7.       return a.equals(b);
  8.     }
  9.   })
  10.   .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  11.   .assertOf(SubscriberFusion.<Integer>assertFuseable())
  12.   .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.SYNC))
  13.   .assertResult(1, 2, 3, 2, 4, 1, 2);
  14. }

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

  1. .to(new ConvertToCylonDetector<Object>())
  2. .beep(new Predicate<Object>() {
  3.   @Override

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

  1. @Test
  2. public void syncArrayHidden() {
  3.   Flowable.fromArray(new Integer[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 })
  4.   .hide()
  5.   .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  6.   .assertOf(SubscriberFusion.<Integer>assertNotFuseable())
  7.   .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.NONE))
  8.   .assertValues(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
  9.   .assertNoErrors()
  10.   .assertComplete();
  11. }

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

  1. @Test
  2. public void syncRangeHidden() {
  3.   Flowable.range(1, 10).hide()
  4.   .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  5.   .assertOf(SubscriberFusion.<Integer>assertNotFuseable())
  6.   .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.NONE))
  7.   .assertValues(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
  8.   .assertNoErrors()
  9.   .assertComplete();
  10. }

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

  1. @Test
  2. public void directComparerConditionalFused() {
  3.   Flowable.fromArray(1, 2, 2, 3, 2, 4, 1, 1, 2)
  4.   .distinctUntilChanged(new BiPredicate<Integer, Integer>() {
  5.     @Override
  6.     public boolean test(Integer a, Integer b) {
  7.       return a.equals(b);
  8.     }
  9.   })
  10.   .filter(new Predicate<Integer>() {
  11.     @Override
  12.     public boolean test(Integer v) {
  13.       return true;
  14.     }
  15.   })
  16.   .to(SubscriberFusion.<Integer>test(Long.MAX_VALUE, QueueFuseable.ANY, false))
  17.   .assertOf(SubscriberFusion.<Integer>assertFuseable())
  18.   .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueFuseable.SYNC))
  19.   .assertResult(1, 2, 3, 2, 4, 1, 2);
  20. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test
  2. public void firstElement() {
  3.   Assert.assertEquals((Integer)1, Flowable.range(1, 5)
  4.   .to(FlowableInterop.firstElement()).get());
  5. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test
  2. public void lastElement() {
  3.   Assert.assertEquals((Integer)5, Flowable.range(1, 5)
  4.   .to(FlowableInterop.lastElement()).get());
  5. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test
  2. public void last() {
  3.   TestHelper.assertFuture(5, Flowable.range(1, 5)
  4.       .to(FlowableInterop.last())
  5.   );
  6. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test
  2. public void first() {
  3.   TestHelper.assertFuture(1, Flowable.range(1, 5)
  4.       .to(FlowableInterop.first())
  5.   );
  6. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test(expected = NoSuchElementException.class)
  2. public void firstEmpty() {
  3.   TestHelper.assertFuture(null, Flowable.empty()
  4.       .to(FlowableInterop.first())
  5.   );
  6. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test(expected = NoSuchElementException.class)
  2. public void lastEmpty() {
  3.   TestHelper.assertFuture(null, Flowable.empty()
  4.       .to(FlowableInterop.last())
  5.   );
  6. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test(expected = NoSuchElementException.class)
  2. public void singleEmpty() {
  3.   TestHelper.assertFuture(null, Flowable.empty()
  4.       .to(FlowableInterop.single())
  5.   );
  6. }

代码示例来源：origin: akarnokd/RxJava2Jdk8Interop

  1. @Test
  2. public void single() {
  3.   TestHelper.assertFuture(1, Flowable.just(1)
  4.       .to(FlowableInterop.single())
  5.   );
  6. }

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

Flowable

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Flowable类方法

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